diff --git a/scouter/activities/pydruid.py b/scouter/activities/pydruid.py index cb9998c..ec0cc21 100644 --- a/scouter/activities/pydruid.py +++ b/scouter/activities/pydruid.py @@ -55,6 +55,10 @@ class Druid(BaseActivity): interval = f"{last_data_timestamp.isoformat()}Z/{end_time.isoformat()}Z" + self.info( + f"Loading data from Druid: {datasource} with interval: {interval}" + ) + builder = QueryBuilder() query = builder.scan(