Skip to content

Commit

Permalink
Move ensure_healthy() to while loop
Browse files Browse the repository at this point in the history
  • Loading branch information
PeiwenGaoMS committed Mar 7, 2024
1 parent ef4dee7 commit 8090b23
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -289,13 +289,13 @@ def _monitor_workers_and_process_tasks_in_thread(
):
# Get the process info of the thread monitoring from the manager.
index, process_id, process_name = self._processes_manager.get_process_info(index)
self._processes_manager.ensure_healthy()

# The main loop of the thread, responsible for getting tasks from the task queue and
# processing them through the input queue, while also monitoring for terminate signals.
# Currently, it exits this loop only upon receiving a terminate signal (TERMINATE_SIGNAL).
exit_loop = False
while not exit_loop:
self._processes_manager.ensure_healthy()
while True:
try:
# Get task from task_queue
Expand Down

0 comments on commit 8090b23

Please sign in to comment.