feat: Added logs to identify which platform is being processed!

TogetherCrew · Dec 8, 2024 · df0b3f3 · df0b3f3
1 parent dc36229
commit df0b3f3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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"]