Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
17 changes: 16 additions & 1 deletion py_src/taskito/app.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,19 @@
"""Main Queue class and @task decorator."""
"""Main Queue class and @task decorator.

The Queue class is composed from multiple mixins for organization:

- ``QueueInspectionMixin`` (mixins.py) — read-only inspection, stats, queries
- ``QueueOperationsMixin`` (mixins.py) — write operations (cancel, purge, archive, etc.)
- ``QueueLockMixin`` (mixins.py) — distributed locking
- ``AsyncQueueMixin`` (async_support/mixins.py) — ``a*`` async wrappers for all sync methods

The Queue class itself (this file) handles:
- Constructor and storage backend initialization
- @task() and @periodic() decorators with task registration
- enqueue() / enqueue_many() job submission
- run_worker() worker lifecycle (signals, heartbeat, resources)
- Event bus and webhook management
"""

from __future__ import annotations

Expand Down
2 changes: 1 addition & 1 deletion py_src/taskito/prefork/child.py
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,7 @@ def main() -> None:
msg = json.loads(line)

if msg.get("type") == "shutdown":
logger.info("shutdown received")
sys.stdout.flush()
break

if msg.get("type") == "job":
Expand Down
Loading