From 2a9f929dbc8439adc17cc37326113f913a48a9c8 Mon Sep 17 00:00:00 2001 From: Jasper Ginn Date: Fri, 1 Mar 2024 17:28:41 +0100 Subject: [PATCH] chore: docstring --- .../src/luchtmeetnet_ingestion/sensors.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py b/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py index 9553224..d0b4aac 100644 --- a/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py +++ b/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py @@ -20,10 +20,10 @@ def slack_message(context: SensorEvaluationContext, **kwargs): Job "{kwargs.get('monitored_job_name')}" in repository "luchtmeetnet_ingestion", environment "{environment}" and run key "{kwargs.get('run_key')}" has completed for {kwargs.get('partitions_total')} partitions: - Successful partitions => {kwargs.get('partitions_successful')} - Failed partitions => {kwargs.get('partitions_failed')} - Upstream partition keys => {kwargs.get('all_upstream_partitions')[:5]}... (truncated) - Downstream partition key => {kwargs.get('downstream_partition_key')} + Successful partitions\t\t=>\t{kwargs.get('partitions_successful')} + Failed partitions\t\t\t=>\t{kwargs.get('partitions_failed')} + Upstream partition keys\t\t=>\t{kwargs.get('all_upstream_partitions')[:5]}... (truncated) + Downstream partition key\t=>\t{kwargs.get('downstream_partition_key')} Sensor "{context.sensor_name}" triggered downstream job "{kwargs.get('downstream_job_name')}" with partition key "{kwargs.get('downstream_partition_key')}".