pipeworks_mud_mapper.services.io_queue

Background I/O queue for long-running file operations.

This module provides a tiny thread pool and job registry so callbacks can offload disk-heavy operations without blocking the UI thread.

Classes

IOJobRegistry

Thread-safe registry for background I/O jobs.

Functions

submit_io_job(func, *args, **kwargs)	Submit a background I/O job and return its id.
get_io_job_status(job_id)	Return the status dict for a job id.
forget_io_job(job_id)	Remove a job id from the registry.

Module Contents

class pipeworks_mud_mapper.services.io_queue.IOJobRegistry(max_workers=2)

Thread-safe registry for background I/O jobs.

submit(func, *args, **kwargs)

Submit a job and return the job id.

status(job_id)

Return status info for a job id.

forget(job_id)

Remove a job id from the registry.

pipeworks_mud_mapper.services.io_queue.submit_io_job(func, *args, **kwargs)

Submit a background I/O job and return its id.

pipeworks_mud_mapper.services.io_queue.get_io_job_status(job_id)

Return the status dict for a job id.

pipeworks_mud_mapper.services.io_queue.forget_io_job(job_id)

Remove a job id from the registry.