diff --git a/execution/run_uc.py b/execution/run_uc.py
index f25d2555e9c5de0d83f3ec5a7056cad0d3ea3b8c..173b8820cee94a12f9ceff8a63288fe1f90a70a0 100644
--- a/execution/run_uc.py
+++ b/execution/run_uc.py
@@ -325,11 +325,13 @@ def delete_topics(topics):
"""
print('Delete topics from Kafka')
+ topics_delete = 'theodolite-.*|' + '|'.join([ti[0] for ti in topics])
+
num_topics_command = [
'/bin/sh',
'-c',
f'kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list \
- | sed -n -E "/^(theodolite-.*|input|output|configuration)\
+ | sed -n -E "/^({topics_delete})\
( - marked for deletion)?$/p" | wc -l'
]
@@ -337,7 +339,7 @@ def delete_topics(topics):
'/bin/sh',
'-c',
f'kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete \
- --topic "input|output|configuration|theodolite-.*"'
+ --topic "{topics_delete}"'
]
# Wait that topics get deleted