Compare commits
No commits in common. "3d195df1a743691a9335edeeb8b988ac3026adc5" and "0e836b1d92d7720b19bc3a27c34ddc103f7bec58" have entirely different histories.
3d195df1a7
...
0e836b1d92
@ -18,7 +18,7 @@ class QueuesException(Exception):
|
|||||||
class TasksHandlerMixin:
|
class TasksHandlerMixin:
|
||||||
def poll(self):
|
def poll(self):
|
||||||
while True:
|
while True:
|
||||||
response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}).json()
|
response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name})
|
||||||
task = response.get('task')
|
task = response.get('task')
|
||||||
if not task:
|
if not task:
|
||||||
time.sleep(0.2)
|
time.sleep(0.2)
|
||||||
|
Loading…
Reference in New Issue
Block a user