Add missing assert

tradewelltech · Aug 21, 2023 · 86b924f · 86b924f
1 parent 1db7fca
commit 86b924f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/test_kafka.py b/tests/test_kafka.py
@@ -1320,4 +1320,4 @@ def test_runtime_sink_topic():
     ]
 
     dag.execute()
-    runtime_sink_topic.serialize(dag.get_cycle_id()) == []
+    assert runtime_sink_topic.serialize(dag.get_cycle_id()) == []