Skip to content

Commit

Permalink
Merge pull request #368 from mvdbeek/dont_overload_on_exception
Browse files Browse the repository at this point in the history
Don't immediately resume ``_monitor_active_jobs`` on exception
  • Loading branch information
mvdbeek authored Jun 18, 2024
2 parents 12f1349 + 5bc3792 commit e726e5a
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions pulsar/managers/stateful.py
Original file line number Diff line number Diff line change
Expand Up @@ -370,6 +370,9 @@ def _run(self):
self._monitor_active_jobs()
except Exception:
log.exception("Failure in stateful manager monitor step.")
# This should hopefully be a rare event.
# Let's not hammer the system with job lookups
time.sleep(1)

def _monitor_active_jobs(self):
active_job_ids = self.stateful_manager.active_jobs.active_job_ids()
Expand Down

0 comments on commit e726e5a

Please sign in to comment.