Skip to content

Commit

Permalink
Fix task process wait CPU usage
Browse files Browse the repository at this point in the history
  • Loading branch information
Dany9966 committed Dec 19, 2024
1 parent 7f622c3 commit dbd2476
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions coriolis/worker/rpc/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
import shutil
import signal
import sys
import time

import eventlet
from oslo_config import cfg
Expand Down Expand Up @@ -143,6 +144,7 @@ def _handle_mp_log_events(self, p, mp_log_q):
except queue.Empty:
if not p.is_alive():
break
time.sleep(.2)

def _get_custom_ld_path(self, original_ld_path, extra_library_paths):
if not isinstance(extra_library_paths, list):
Expand Down Expand Up @@ -210,6 +212,7 @@ def _wait_for_process(self, p, mp_q):
except BaseException:
pass
break
time.sleep(.2)
return result

def _exec_task_process(
Expand Down

0 comments on commit dbd2476

Please sign in to comment.