We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 626d017 commit 7d6569dCopy full SHA for 7d6569d
pyres/worker.py
@@ -136,13 +136,18 @@ def work(self, interval=5):
136
logger.info("starting")
137
self.startup()
138
139
+ check_worker_registration_wait = 3
140
+
141
while True:
142
if self._shutdown:
143
logger.info('shutdown scheduled')
144
break
145
- if not self.is_registered():
- self.register_worker()
146
+ check_worker_registration_wait -= 1
147
+ if not check_worker_registration_wait:
148
149
+ if not self.is_registered():
150
+ self.register_worker()
151
152
job = self.reserve(interval)
153
0 commit comments