LICENSE
README.md
pyproject.toml
src/qtasks/__init__.py
src/qtasks/__main__.py
src/qtasks/_state.py
src/qtasks/logs.py
src/qtasks/qtasks.py
src/qtasks/version.py
src/qtasks.egg-info/PKG-INFO
src/qtasks.egg-info/SOURCES.txt
src/qtasks.egg-info/dependency_links.txt
src/qtasks.egg-info/entry_points.txt
src/qtasks.egg-info/requires.txt
src/qtasks.egg-info/top_level.txt
src/qtasks/asyncio/__init__.py
src/qtasks/asyncio/qtasks.py
src/qtasks/base/__init__.py
src/qtasks/base/qtasks.py
src/qtasks/brokers/__init__.py
src/qtasks/brokers/async_kafka.py
src/qtasks/brokers/async_rabbitmq.py
src/qtasks/brokers/async_redis.py
src/qtasks/brokers/base.py
src/qtasks/brokers/sync_kafka.py
src/qtasks/brokers/sync_rabbitmq.py
src/qtasks/brokers/sync_redis.py
src/qtasks/configs/__init__.py
src/qtasks/configs/async_redisglobalconfig.py
src/qtasks/configs/base.py
src/qtasks/configs/config.py
src/qtasks/configs/sync_redisglobalconfig.py
src/qtasks/contexts/__init__.py
src/qtasks/contexts/async_context.py
src/qtasks/contexts/sync_context.py
src/qtasks/contrib/__init__.py
src/qtasks/contrib/redis/__init__.py
src/qtasks/contrib/redis/async_queue_client.py
src/qtasks/contrib/redis/sync_queue_client.py
src/qtasks/enums/__init__.py
src/qtasks/enums/task_status.py
src/qtasks/exc/__init__.py
src/qtasks/exc/task.py
src/qtasks/executors/__init__.py
src/qtasks/executors/async_task_executor.py
src/qtasks/executors/base.py
src/qtasks/executors/sync_task_executor.py
src/qtasks/middlewares/__init__.py
src/qtasks/middlewares/base.py
src/qtasks/middlewares/task.py
src/qtasks/plugins/base.py
src/qtasks/plugins/retries/__init__.py
src/qtasks/plugins/retries/async_retry.py
src/qtasks/plugins/retries/sync_retry.py
src/qtasks/registries/__init__.py
src/qtasks/registries/async_task_decorator.py
src/qtasks/registries/sync_task_decorator.py
src/qtasks/registries/task_registry.py
src/qtasks/results/__init__.py
src/qtasks/results/async_result.py
src/qtasks/results/sync_result.py
src/qtasks/routers/__init__.py
src/qtasks/routers/router.py
src/qtasks/schemas/__init__.py
src/qtasks/schemas/global_config.py
src/qtasks/schemas/inits.py
src/qtasks/schemas/task.py
src/qtasks/schemas/task_exec.py
src/qtasks/schemas/task_status.py
src/qtasks/schemas/test.py
src/qtasks/starters/__init__.py
src/qtasks/starters/async_starter.py
src/qtasks/starters/base.py
src/qtasks/starters/sync_starter.py
src/qtasks/storages/__init__.py
src/qtasks/storages/async_redis.py
src/qtasks/storages/base.py
src/qtasks/storages/sync_redis.py
src/qtasks/tests/__init__.py
src/qtasks/tests/async_classes.py
src/qtasks/tests/async_testcase.py
src/qtasks/tests/base.py
src/qtasks/tests/sync_testcase.py
src/qtasks/timers/__init__.py
src/qtasks/timers/async_timer.py
src/qtasks/timers/base.py
src/qtasks/timers/sync_timer.py
src/qtasks/types/__init__.py
src/qtasks/types/annotations.py
src/qtasks/utils/__init__.py
src/qtasks/utils/registry.py
src/qtasks/workers/__init__.py
src/qtasks/workers/async_worker.py
src/qtasks/workers/base.py
src/qtasks/workers/sync_worker.py
tests/test_async_task.py
tests/test_sync_task.py