Skip to content

Commit 2eaea23

Browse files
committed
add kafka.timestamp to alert metadata
1 parent d682e71 commit 2eaea23

File tree

1 file changed

+1
-0
lines changed
  • broker/cloud_run/lsst/ps_to_storage

1 file changed

+1
-0
lines changed

broker/cloud_run/lsst/ps_to_storage/main.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,5 +106,6 @@ def _create_file_metadata(alert: pittgoogle.Alert, event_id: str) -> dict:
106106
metadata["_".join(alert.get_key("sourceid"))] = alert.sourceid
107107
metadata["_".join(alert.get_key("ra"))] = alert.ra
108108
metadata["_".join(alert.get_key("dec"))] = alert.dec
109+
metadata["kafka.timestamp"] = alert.attributes["kafka.timestamp"]
109110

110111
return metadata

0 commit comments

Comments
 (0)