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.
1 parent 9168863 commit 93ad003Copy full SHA for 93ad003
taskiq/cli/worker/process_manager.py
@@ -83,7 +83,7 @@ def handle(
83
target=worker_func,
84
kwargs={"args": args},
85
name=f"worker-{self.worker_num}",
86
- daemon=True,
+ daemon=False,
87
)
88
new_process.start()
89
logger.info(f"Process {new_process.name} restarted with pid {new_process.pid}")
@@ -193,7 +193,7 @@ def prepare_workers(self) -> None:
193
target=self.worker_function,
194
kwargs={"args": self.args},
195
name=f"worker-{process}",
196
197
198
work_proc.start()
199
logger.info(
0 commit comments