diff --git a/scouter/activities/pydruid.py b/scouter/activities/pydruid.py index b74b7ae..e3f1750 100644 --- a/scouter/activities/pydruid.py +++ b/scouter/activities/pydruid.py @@ -41,8 +41,7 @@ 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) + last_data_timestamp = last_data_timestamp if last_data_timestamp is not None else '1970-01-01 00:00:00' self.debug( f"Loading data from Druid: {input_data}", metadata=metadata)