fix
This commit is contained in:
parent
f27122ce56
commit
5a8d6c6488
@ -21,6 +21,7 @@ class TasksHandlerMixin:
|
|||||||
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}).json()
|
||||||
except requests.JSONDecodeError:
|
except requests.JSONDecodeError:
|
||||||
print('Unable to decode json')
|
print('Unable to decode json')
|
||||||
|
time.sleep(3)
|
||||||
continue
|
continue
|
||||||
task = response.get('task')
|
task = response.get('task')
|
||||||
if not task:
|
if not task:
|
||||||
|
Loading…
Reference in New Issue
Block a user