betty.job.executor.asyncio module#

Job execution using async/await.

final class betty.job.executor.asyncio.AsyncExecutor#

Bases: Executor

A job executor using async/await.

__init__(scheduler: Scheduler, *, concurrency: int = 1)#
async cancel() None#

Stop the executor and cancel any pending jobs.

async complete() None#

Wait for any pending jobs to complete and stop the executor.

async start() None#

Start working on jobs.