diff --git a/dags/hivemind_telegram_etl.py b/dags/hivemind_telegram_etl.py index 44dac064..44513c33 100644 --- a/dags/hivemind_telegram_etl.py +++ b/dags/hivemind_telegram_etl.py @@ -24,12 +24,13 @@ def fetch_chat_ids() -> list[tuple[str, str]]: Returns --------- - chat_info : list[tuple[str, str]] + chat_infos : list[tuple[str, str]] a list of Telegram chat id and name """ load_dotenv() - chat_info = TelegramChats.extract_chats() - return chat_info + chat_infos = TelegramChats.extract_chats() + logging.info(f"Extracted chats: {chat_infos}") + return chat_infos @task def chat_existence(chat_info: tuple[str, str]) -> tuple[str, str]: