Skip to content

Commit

Permalink
chore: remove unused function
Browse files Browse the repository at this point in the history
  • Loading branch information
JasperHG90 committed Mar 24, 2024
1 parent 622bfa0 commit ae01d43
Showing 1 changed file with 0 additions and 18 deletions.
18 changes: 0 additions & 18 deletions dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down

0 comments on commit ae01d43

Please sign in to comment.