fix mypy

airbnb · Aug 25, 2023 · f85b109 · f85b109
1 parent b5691c3
commit f85b109
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/superset/utils/async_query_manager.py b/superset/utils/async_query_manager.py
@@ -192,5 +192,16 @@ def update_job(
         logger.debug("********** logging event data to stream %s", scoped_stream_name)
         logger.debug(event_data)
 
-        self._redis.xadd(scoped_stream_name, event_data, "*", self._stream_limit)
-        self._redis.xadd(full_stream_name, event_data, "*", self._stream_limit_firehose)
+        self._redis.xadd(
+            scoped_stream_name,
+            event_data,  # type: ignore
+            "*",
+            self._stream_limit,
+        )
+
+        self._redis.xadd(
+            full_stream_name,
+            event_data,  # type: ignore
+            "*",
+            self._stream_limit_firehose,
+        )