Job Trigger

messaging/pubsub-consumer.py

@@ -17,5 +17,5 @@ for msg in ch.listen():
         latency = (r - data['timestamp']) / 1000 / 1000
         print(f"{latency:.2f}ms | msg: { json.dumps(data) }")
     except Exception as ex:
-        print(f"Could not process message '{ msg }' caused by { ex }")
+        print(f"Could not process message: '{ msg }' caused by { ex }")