v0.11.2

What's Changed

• Clear redis pool after disconnect by @heimtathurs in #511
• Bump version to 0.11.2 by @seedofjoy in #512

New Contributors

• @heimtathurs made their first contribution in #511

Full Changelog: v0.11.1...v0.11.2

v0.11.1

• Add Python 3.11 support (with evo-aioredis dependency instead of aioredis)
• Remove pydantic dependency
• Remove aioredis from dependencies to allow choose between aioredis and evo-aioredis - fork with Python 3.11 compatability

v0.11.0

• Added ability to optionally pass ctx to the task, like this:

@task(with_ctx=True)
def foobar(ctx):
    log.info('Foobar try %s', ctx['job_try'])

ctx contains: job_id, job_try, enqueue_time, score, metadata + all worker's ctx (including custom context which can be passed via on_startup). Thanks to @kindermax (#426)!

v0.10.2

• Add proper typing for functions wrapped with the @task decorator. Mypy will now check that parameters are passed correctly when calling func() and func.delay()

v0.10.1

• Add sentinel_timeout (defaults to 0.2) param to RedisSettings

0.10.0

Breaking change: Rename darq.worker.Function to darq.worker.Task
Made job to task naming migration
Add max_jobs parameter to CLI (thanks to @antonmyronyuk)
Fixed bug with expires argument: default_job_expires could not be replaced with None in @task or .apply_async

0.9.0

Breaking change: Add scheduler_ctx param to on_scheduler_startup and on_scheduler_shutdown to share data between this callbacks. It already has ctx['redis'] - instance of ArqRedis

0.8.0

• Breaking change: Changed CLI command format. Before: darq some_project.darq_app.darq. Now: darq -A some_project.darq_app.darq worker
• Breaking change: Scheduler (cron jobs) now run's seperate from worker (see darq scheduler command)
• Breaking change: Changed some function signatures (rename arguments)
• Breaking change: Remove redis_pool param from Darq app
• Add on_scheduler_startup and on_scheduler_shutdown callbacks

0.7.2

• Fix some types (cron, OnJobPrepublishType)
• on_job_prerun now runs before "task started" log and on_job_postrun now runs after "task finished" log

0.7.1

.apply_async: Make args and kwargs arguments optional