Skip to content

Commit 30a7168

Browse files
committed
Always check before cleanup of workers.
1 parent 0c50e0c commit 30a7168

1 file changed

Lines changed: 7 additions & 3 deletions

File tree

  • PyFunceble/ext/process_manager

PyFunceble/ext/process_manager/core.py

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -691,7 +691,8 @@ def remove_dependent_manager(
691691
The dependent manager to remove.
692692
"""
693693

694-
self.dependent_managers.remove(manager)
694+
if manager in self.dependent_managers:
695+
self.dependent_managers.remove(manager)
695696

696697
return self
697698

@@ -1001,8 +1002,11 @@ def spawn_workers(
10011002
"__immediate_shutdown__", destination_worker=worker_to_kill.name
10021003
)
10031004

1004-
self.running_workers.remove(worker_to_kill)
1005-
self.created_workers.remove(worker_to_kill)
1005+
if worker_to_kill in self.running_workers:
1006+
self.running_workers.remove(worker_to_kill)
1007+
1008+
if worker_to_kill in self.created_workers:
1009+
self.created_workers.remove(worker_to_kill)
10061010

10071011
return self
10081012
return self

0 commit comments

Comments
 (0)