Add proper cleanup to kafka test

This commit is contained in:
János Benjamin Antal 2024-01-16 16:03:44 +00:00
parent b62a4e9255
commit 5a178ce1ef

View File

@ -5008,6 +5008,14 @@ def test_multiple_read_in_materialized_views(kafka_cluster, max_retries=15):
)
assert res == expected_result
kafka_delete_topic(admin_client, topic)
instance.query(
f"""
DROP TABLE test.kafka_multiple_read_input;
DROP TABLE test.kafka_multiple_read_table;
DROP TABLE test.kafka_multiple_read_mv;
""")
if __name__ == "__main__":
cluster.start()