From ae01d43214384c97a5363a5ae3216915acb6afe5 Mon Sep 17 00:00:00 2001 From: Jasper Ginn Date: Sun, 24 Mar 2024 19:22:39 +0100 Subject: [PATCH] chore: remove unused function --- .../src/luchtmeetnet_ingestion/sensors.py | 18 ------------------ 1 file changed, 18 deletions(-) diff --git a/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py b/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py index 131c75e..f9362cb 100644 --- a/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py +++ b/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py @@ -14,24 +14,6 @@ environment = os.getenv("ENVIRONMENT", "dev") -def post_job_success(context: SensorEvaluationContext, gcp_metrics: GcpMetricsResource, value: int): - context.log.info("Posting metrics to GCP") - context.log.debug(context.run.tags) - labels = { - "job_name": context.asset_key, - "partition": context.partition_key, - "run_id": context.run_id, - "trigger_type": "asset", - "trigger_name": "test", - } - # Post metrics to GCP - gcp_metrics.post_time_series( - series_type="custom.googleapis.com/dagster/job_success", - value={"bool_value": value}, - metric_labels=labels, - ) - - def parse_run_trigger(tags: typing.Dict[str, str]) -> typing.Dict[str, str]: if tags.get("dagster/backfill") is not None: trigger_type = "backfill"