Skip to content

Commit e23cbda

Browse files
fix storage monitor race condition (#1454)
1 parent a02b537 commit e23cbda

1 file changed

Lines changed: 5 additions & 9 deletions

File tree

lithops/monitor.py

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -460,21 +460,17 @@ def run(self):
460460
previous_log = None
461461
log_time = 0
462462

463-
while not self._all_ready():
464-
time.sleep(wait_dur_sec)
465-
wait_dur_sec = self.monitoring_interval
466-
log_time += wait_dur_sec
467-
468-
if not self.should_run:
469-
logger.debug(f'ExecutorID {self.executor_id} - Monitor stopped externally')
470-
break
471-
463+
while self.should_run:
472464
try:
473465
new_callids_done, previous_log, log_time = self._poll_and_process_job_status(previous_log, log_time)
474466
if new_callids_done:
475467
wait_dur_sec = self.monitoring_interval / 5
468+
else:
469+
wait_dur_sec = self.monitoring_interval
476470
except Exception as e:
477471
logger.error(f'ExecutorID {self.executor_id} - Error during monitor: {e}', exc_info=True)
472+
time.sleep(wait_dur_sec)
473+
log_time += wait_dur_sec
478474

479475
self._poll_and_process_job_status(previous_log, log_time)
480476

0 commit comments

Comments
 (0)