From dc7a4b992b7c76bbd69abe22119069997a6de510 Mon Sep 17 00:00:00 2001
From: Nikita Shamaev <nashamaye1@mts.ru>
Date: Thu, 8 Sep 2022 20:03:03 +0300
Subject: [PATCH] dont broadcast via Celery if DEBUG=True
---
tgbot/handlers/broadcast_message/handlers.py | 20 ++++++++++++++------
1 file changed, 14 insertions(+), 6 deletions(-)
diff --git a/tgbot/handlers/broadcast_message/handlers.py b/tgbot/handlers/broadcast_message/handlers.py
index bb0f67d..0b52706 100644
--- a/tgbot/handlers/broadcast_message/handlers.py
+++ b/tgbot/handlers/broadcast_message/handlers.py
@@ -4,6 +4,7 @@
from telegram import Update
from telegram.ext import CallbackContext
+from dtb.settings import DEBUG
from .manage_data import CONFIRM_DECLINE_BROADCAST, CONFIRM_BROADCAST
from .keyboards import keyboard_confirm_decline_broadcasting
from .static_text import broadcast_command, broadcast_wrong_format, broadcast_no_access, error_with_html, \
@@ -60,12 +61,19 @@ def broadcast_decision_handler(update: Update, context: CallbackContext) -> None
admin_text = message_is_sent
user_ids = list(User.objects.all().values_list('user_id', flat=True))
- # send in async mode via celery
- broadcast_message.delay(
- user_ids=user_ids,
- text=text,
- entities=entities_for_celery,
- )
+ if DEBUG:
+ broadcast_message(
+ user_ids=user_ids,
+ text=text,
+ entities=entities_for_celery,
+ )
+ else:
+ # send in async mode via celery
+ broadcast_message.delay(
+ user_ids=user_ids,
+ text=text,
+ entities=entities_for_celery,
+ )
else:
context.bot.send_message(
chat_id=update.callback_query.message.chat_id,