fix: f-string

nuvla · Jun 12, 2024 · eed448e · eed448e
1 parent 59a43b9
commit eed448e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/notify-mqtt.py b/src/notify-mqtt.py
@@ -101,7 +101,7 @@ def worker(workq: multiprocessing.Queue):
             try:
                 send_message(message_content(msg.value), msg.value.get('DESTINATION'))
             except Exception as ex:
-                log_local.error(f'Failed sending {msg} to {msg.value.get('DESTINATION')}: {ex}')
+                log_local.error(f"Failed sending {msg} to {msg.value.get('DESTINATION')}: {ex}")
                 PROCESS_STATES.state('error - recoverable')
                 NOTIFICATIONS_ERROR.labels('mqtt', f'{msg.value.get("NAME") or msg.value["SUBS_NAME"]}', msg.value.get('MQTT_TOPIC'), type(ex)).inc()
                 continue
@@ -111,4 +111,4 @@ def worker(workq: multiprocessing.Queue):
 
 if __name__ == "__main__":
     start_http_server(prometheus_exporter_port(), registry=registry)
-    main(worker, KAFKA_TOPIC, KAFKA_GROUP_ID)
+    main(worker, KAFKA_TOPIC, KAFKA_GROUP_ID)