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)