jlengrand/bugsink
1
0
Fork 0
mirror of https://github.com/jlengrand/bugsink.git synced 2026-03-10 08:01:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

snappea foreman comment clarifications

Browse Source
This commit is contained in:
Klaas van Schelven
2024-08-27 22:17:28 +02:00
parent 98b08cb2e3
commit 46046f894c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
snappea/foreman.py
View File

@@ -257,7 +257,7 @@ class Foreman:
with contextlib.suppress(FileNotFoundError):
os.unlink(os.path.join(self.settings.WAKEUP_CALLS_DIR, event.name))
self.check_for_stopping() # always check after .read()
self.check_for_stopping() # check after .read() - it may have unblocked via handle_signal()
while self.create_workers() == self.settings.TASK_QS_LIMIT:
pass # `== TASK_QS_LIMIT`: as documented above
@@ -297,7 +297,7 @@ class Foreman:
logger.debug("Create workers: Checking (maybe waiting) for available worker slots")
self.worker_semaphore.acquire()
logger.debug("Create workers: Worker slot available")
self.check_for_stopping() # always check after .acquire()
self.check_for_stopping() # check after .acquire() - it may have unblocked via handle_signal()
task_id = task.id
try: