update logging when reveicing events from k8s stream

navikt · Jun 15, 2021 · 3a5d2e1 · 3a5d2e1
1 parent 71f5914
commit 3a5d2e1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/main.py b/main.py
@@ -30,12 +30,12 @@ def init_kube_client():
 
 
 def app_watcher_callback(e):
-    logger.info("Event: %s %s (%s)" % (e['type'], e['object']['metadata']['name'], e['object']['metadata']['uid']))
+    logger.info("Received event: %s %s (%s)" % (e['type'], e['object']['metadata']['name'], e['object']['metadata']['uid']))
     e.pop("type")
     e["cluster"] = os.environ["NAIS_CLUSTER_NAME"]
     e["application_type"] = "Nais_App"
-    logger.info("Posting " + e['object']['metadata']['name'] + " from cluster: " + e['cluster']
-                + " to ingress-retriever prod")
+    logger.info("Publishing " + e['object']['metadata']['name'] + " from cluster: " + e['cluster']
+                + f" to topic {os.environ['KAFKA_TOPIC']}")
     producer.send(e)