From c509cb0b326b04fbc0318e95850f30f513f43e9e Mon Sep 17 00:00:00 2001 From: Egor Matveev Date: Sat, 28 Dec 2024 13:49:39 +0300 Subject: [PATCH 1/4] fix --- utils/queues.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/utils/queues.py b/utils/queues.py index c00a18c..173b017 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -17,7 +17,10 @@ class QueuesException(Exception): class TasksHandlerMixin: def poll(self): 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}) + print('Got status', response.status_code) + print('Got body', response.content.decode('utf-8')) + response = response.json() task = response.get('task') if not task: time.sleep(0.2) -- 2.45.2 From f27122ce567d884dd85e8dd8f28b2b17adc36adc Mon Sep 17 00:00:00 2001 From: Egor Matveev Date: Sat, 28 Dec 2024 14:18:34 +0300 Subject: [PATCH 2/4] fix --- utils/queues.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/utils/queues.py b/utils/queues.py index 173b017..10278b5 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -17,10 +17,11 @@ class QueuesException(Exception): class TasksHandlerMixin: def poll(self): while True: - response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}) - print('Got status', response.status_code) - print('Got body', response.content.decode('utf-8')) - response = response.json() + try: + response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}).json() + except requests.JSONDecodeError: + print('Unable to decode json') + continue task = response.get('task') if not task: time.sleep(0.2) -- 2.45.2 From 5a8d6c64880ff03b70566d5c5ca194dc8a2b52fb Mon Sep 17 00:00:00 2001 From: Egor Matveev Date: Sat, 28 Dec 2024 14:23:20 +0300 Subject: [PATCH 3/4] fix --- utils/queues.py | 1 + 1 file changed, 1 insertion(+) diff --git a/utils/queues.py b/utils/queues.py index 10278b5..dc0f219 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -21,6 +21,7 @@ class TasksHandlerMixin: response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}).json() except requests.JSONDecodeError: print('Unable to decode json') + time.sleep(3) continue task = response.get('task') if not task: -- 2.45.2 From 8828bfd05b14c91b239e510c35872ac6ab73f5ab Mon Sep 17 00:00:00 2001 From: Egor Matveev Date: Tue, 31 Dec 2024 02:49:03 +0300 Subject: [PATCH 4/4] fix --- daemons/poll.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/daemons/poll.py b/daemons/poll.py index d7169ee..d4fe4a4 100644 --- a/daemons/poll.py +++ b/daemons/poll.py @@ -1,6 +1,7 @@ import telebot import multiprocessing import time +import json from daemons import base from utils import platform @@ -41,5 +42,5 @@ class Daemon(base.Daemon): bot = telebot.TeleBot(token) @bot.message_handler(content_types=['audio', 'photo', 'voice', 'video', 'document', 'animation', 'text', 'location', 'contact', 'sticker', 'video_note']) def do_action(message: telebot.types.Message): - queues.set_task(queue, message.json, 1) + queues.set_task(queue, json.loads(message.json), 1) bot.polling() -- 2.45.2