diff --git a/ingest/api/send_mqtt.py b/ingest/api/send_mqtt.py
index c70714b6..3b351b74 100644
--- a/ingest/api/send_mqtt.py
+++ b/ingest/api/send_mqtt.py
@@ -8,7 +8,7 @@
 
 if "MQTT_TOPIC_PREPEND" in os.environ:
     mqtt_topic_prepend = os.getenv("MQTT_TOPIC_PREPEND", "")
-    mqtt_topic_prepend = mqtt_topic_prepend if not mqtt_topic_prepend.endswith("/") else mqtt_topic_prepend + "/"
+    mqtt_topic_prepend = mqtt_topic_prepend if mqtt_topic_prepend.endswith("/") else mqtt_topic_prepend + "/"
 
 
 def connect_mqtt(mqtt_conf: dict):