Skip to content

Commit ce17c69

Browse files
committed
add kafka.timestamp to the file metadata
1 parent 8e8b5a7 commit ce17c69

File tree

1 file changed

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

1 file changed

+1
-0
lines changed

broker/cloud_run/lvk/ps_to_storage/main.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,5 +102,6 @@ def _create_file_metadata(alert: pittgoogle.Alert, event_id: str) -> dict:
102102
metadata["alert_type"] = alert.dict["alert_type"]
103103
metadata["superevent_id"] = alert.dict["superevent_id"]
104104
metadata["schema_version"] = alert.dict["schema_version"]
105+
metadata["kafka.timestamp"] = alert.attributes["kafka.timestamp"]
105106

106107
return metadata

0 commit comments

Comments
 (0)