We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a075186 commit b29f775Copy full SHA for b29f775
pulpcore/tasking/worker.py
@@ -484,6 +484,8 @@ def handle_available_tasks(self):
484
"""
485
keep_looping = True
486
while keep_looping and not self.shutdown_requested:
487
+ # Clear pending wakeups. We are about to handle them anyway.
488
+ self.wakeup = False
489
try:
490
with PGAdvisoryLock(TASK_UNBLOCKING_LOCK):
491
keep_looping = self.unblock_tasks()
0 commit comments