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

Compare commits

base: self:39bca8ead99aa8805cb571b44d537c38b5230dbd
Branches Tags
self:master
self:prod
self:metric
self:dev
..
compare: self:43184acb168b2ed0b6115af42e71c1ec12ae1810
Branches Tags
self:master
self:prod
self:metric
self:dev

No commits in common. "39bca8ead99aa8805cb571b44d537c38b5230dbd" and "43184acb168b2ed0b6115af42e71c1ec12ae1810" have entirely different histories.
39bca8ead9 ... 43184acb16

1 changed files with 4 additions and 5 deletions
Show Stats Expand all files Collapse all files

9
utils/queues.py
View File

@ -17,11 +17,10 @@ class QueuesException(Exception):
class TasksHandlerMixin: class TasksHandlerMixin:
def poll(self): def poll(self):
while True: while True:
try: response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name})
response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}).json() print('Got status', response.status_code)
except requests.JSONDecodeError: print('Got body', response.content.decode('utf-8'))
print('Unable to decode json') response = response.json()
continue
task = response.get('task') task = response.get('task')
if not task: if not task:
time.sleep(0.2) time.sleep(0.2)