appyter.orchestration.dispatcher package

Submodules

appyter.orchestration.dispatcher.core module

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

Bases: collections.OrderedDict

lock = <asyncio.locks.Lock object at 0x7f669dc23c50 [unlocked]>
async appyter.orchestration.dispatcher.core.dispatcher(queued=None, tasks=None, jobs_per_image=1)[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]