appyter.orchestration.dispatcher package¶

Submodules¶

appyter.orchestration.dispatcher.core module¶

class appyter.orchestration.dispatcher.core.LockedOrderedDict[source]¶

Bases: OrderedDict

lock = <asyncio.locks.Lock object at 0x7f793d36c6e0 [unlocked]>¶

async appyter.orchestration.dispatcher.core.dispatch(job_id, job)[source]¶

async appyter.orchestration.dispatcher.core.dispatcher(queued=None, tasks=None, jobs_per_image=1, timeout=None)[source]¶

async appyter.orchestration.dispatcher.core.on_get(request)[source]¶

async appyter.orchestration.dispatcher.core.on_submit(request)[source]¶

async appyter.orchestration.dispatcher.core.slow_put(queue, item)[source]¶: Queue put debouncing

appyter.orchestration.dispatcher.socketio module¶

Module contents¶

appyter.orchestration.dispatcher.create_app(**kwargs)[source]¶