From 3bbc6a6a7930ec24f3a862e21645ecd1a2ac4f2a Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Wed, 2 Jul 2025 10:21:55 -0300 Subject: [PATCH] SIENTIAPDE-1110 Update Druid activity to handle None values for last data timestamp, ensuring default timestamp is set to epoch start. Enhance data loading debug logging for improved traceability. --- scouter/activities/pydruid.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/scouter/activities/pydruid.py b/scouter/activities/pydruid.py index 473c173..b74b7ae 100644 --- a/scouter/activities/pydruid.py +++ b/scouter/activities/pydruid.py @@ -41,6 +41,8 @@ class Druid(BaseActivity): metadata = input_data['metadata'] datasource = f"raw_{input_data['schedule_name']}" last_data_timestamp = input_data['last_data_timestamp'] + last_data_timestamp = last_data_timestamp if last_data_timestamp is not None else datetime( + 1970, 1, 1, 0, 0, 0) self.debug( f"Loading data from Druid: {input_data}", metadata=metadata)