From df0b3f31230639f82635a979b9f4bcdd0471f1e1 Mon Sep 17 00:00:00 2001 From: Mohammad Amin Date: Sun, 8 Dec 2024 12:32:11 +0330 Subject: [PATCH] feat: Added logs to identify which platform is being processed! --- dags/discourse_analyzer_etl.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/dags/discourse_analyzer_etl.py b/dags/discourse_analyzer_etl.py index e296e961..738c0da2 100644 --- a/dags/discourse_analyzer_etl.py +++ b/dags/discourse_analyzer_etl.py @@ -106,6 +106,8 @@ def discourse_etl_raw_data( } ``` """ + logging.info(f"Processing platform: {platform_info}") + platform_id = platform_info["platform_id"] forum_endpoint = platform_info["id"] period = platform_info["period"] @@ -147,6 +149,7 @@ def discourse_etl_raw_members( } ``` """ + logging.info(f"Processing platform: {platform_info}") platform_id = platform_info["platform_id"] forum_endpoint = platform_info["id"] # period = platform_info["period"]