We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
bool
1 parent 8657814 commit ec6f3d3Copy full SHA for ec6f3d3
taskiq/abc/broker.py
@@ -114,9 +114,9 @@ def __init__(
114
self.custom_dependency_context: Dict[Any, Any] = {}
115
self.dependency_overrides: Dict[Any, Any] = {}
116
# True only if broker runs in worker process.
117
- self.is_worker_process: bool = False
+ self.is_worker_process = False
118
# True only if broker runs in scheduler process.
119
- self.is_scheduler_process: bool = False
+ self.is_scheduler_process = False
120
121
def find_task(self, task_name: str) -> Optional[AsyncTaskiqDecoratedTask[Any, Any]]:
122
"""
0 commit comments