(process_pool_executor, manager, db_alias)
return worker_task, queue
Instantiates a queue, and starts a worker task in its own process
Instantiates a queue, and starts a worker task in its own process
Instantiates a queue and starts a worker task in its own process
def get_worker_queue(process_pool_executor, manager, db_alias):
    """
    Instantiates a queue, and starts a worker task in its own process
    """
    queue = manager.JoinableQueue(maxsize=CHUNK_SIZE)
    worker_task = process_pool_executor.submit(worker, queue, db_alias)
    return worker_task, queue
def get_worker_queue ( process_pool_executor , manager , db_alias ) : queue = manager . JoinableQueue ( maxsize = CHUNK_SIZE ) worker_task = process_pool_executor . submit ( worker , queue , db_alias ) return worker_task , queue