Darq

Latest version: v0.11.2

Safety actively analyzes 687959 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 1 of 4

0.11.2

What's Changed
* Clear redis pool after disconnect by heimtathurs in https://github.com/seedofjoy/darq/pull/511
* Bump version to 0.11.2 by seedofjoy in https://github.com/seedofjoy/darq/pull/512

New Contributors
* heimtathurs made their first contribution in https://github.com/seedofjoy/darq/pull/511

**Full Changelog**: https://github.com/seedofjoy/darq/compare/v0.11.1...v0.11.2

0.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

0.11.0

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

python
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 (https://github.com/seedofjoy/darq/pull/426)!

0.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()``

0.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`

Page 1 of 4

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.