self/botalka
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix
All checks were successful
Deploy Prod / Build (pull_request) Successful in 7s
Details
Deploy Prod / Push (pull_request) Successful in 8s
Details
Deploy Prod / Deploy prod (pull_request) Successful in 10s
Details

Browse Source
This commit is contained in:
Egor Matveev 2024-12-28 14:18:34 +03:00
parent c509cb0b32
commit f27122ce56
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
utils/queues.py
View File

@ -17,10 +17,11 @@ 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}) try:
print('Got status', response.status_code) response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}).json()
print('Got body', response.content.decode('utf-8')) except requests.JSONDecodeError:
response = response.json() print('Unable to decode json')
continue
task = response.get('task') task = response.get('task')
if not task: if not task:
time.sleep(0.2) time.sleep(0.2)