[hot-fix]: change follower dag

zizzic · Feb 29, 2024 · 484ab49 · 484ab49
1 parent eb43364
commit 484ab49
Showing 1 changed file with 9 additions and 12 deletions.
diff --git a/dags/streaming/follower.py b/dags/streaming/follower.py
@@ -95,18 +95,15 @@ def get_broad_info(bjid, headers):
             broad_res = get_broad_info(bjid, headers)
 
             try:
-                broad_info = broad_res.get("broad")
-
-                if broad_info:
-                    combined_res = {"broad_info": broad_res}
-
-                    stream_data = {
-                        "streamer_id": s_id,
-                        "afc_s_id": bjid,
-                        "current_time": current_time,
-                        **combined_res,
-                    }
-                    live_stream_data.append(stream_data)
+                combined_res = {"broad_info": broad_res}
+
+                stream_data = {
+                    "streamer_id": s_id,
+                    "afc_s_id": bjid,
+                    "current_time": current_time,
+                    **combined_res,
+                }
+                live_stream_data.append(stream_data)
 
             except (AttributeError, TypeError) as e:
                 error_msg = f"Error occurred: {str(e)}"