From 879c1fdc495939afe04db1d776a21790245fee77 Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Wed, 2 Jul 2025 09:27:02 -0300 Subject: [PATCH] SIENTIAPDE-1110 Add logging for data loading in Druid activity, enhancing traceability of data retrieval intervals. --- scouter/activities/pydruid.py | 4 ++++ 1 file changed, 4 insertions(+) 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(