From ba9a44c49eda8204b85d5e7afcf30dd83ba1d165 Mon Sep 17 00:00:00 2001 From: Jasper Ginn Date: Sun, 24 Mar 2024 19:34:40 +0100 Subject: [PATCH] chore: add code location --- .../luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py | 1 + 1 file changed, 1 insertion(+) diff --git a/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py b/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py index f9362cb..e0c1af7 100644 --- a/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py +++ b/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py @@ -54,6 +54,7 @@ def post_gcp_metrics(context: SensorEvaluationContext, gcp_metrics: GcpMetricsRe "run_id": run_record.dagster_run.run_id, "partition_key": run_record.dagster_run.tags.get("dagster/partition", "N/A"), "environment": environment, + "location": run_record.dagster_run.external_job_origin.location_name, **parse_run_trigger(run_record.dagster_run.tags), } gcp_metrics.post_time_series(