From 208491498f22506051e698abe747b47cfc084fcd Mon Sep 17 00:00:00 2001
From: vitor-aignosi <vitor.santos@aignosi.com.br>
Date: Wed, 2 Jul 2025 10:35:53 -0300
Subject: [PATCH] SIENTIAPDE-1110  Update Druid configuration in values.yaml to
 change port from 8081 to 8888. Refactor pydruid.py to use druid_engine for
 SQLAlchemy connections, enhancing clarity and consistency in data loading
 operations.

---
 scouter/activities/pydruid.py | 6 +++---
 values.yaml                   | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/scouter/activities/pydruid.py b/scouter/activities/pydruid.py
index e3f1750..f19e4bb 100644
--- a/scouter/activities/pydruid.py
+++ b/scouter/activities/pydruid.py
@@ -19,7 +19,7 @@ class Druid(BaseActivity):
 
         self.host = host
         self.port = port
-        self.engine = create_engine(
+        self.druid_engine = create_engine(
             f'druid://{self.host}:{self.port}/druid/v2/sql/')
         logger.info(
             f"Druid client initialized with host: {self.host}, port: {self.port}")
@@ -51,10 +51,10 @@ class Druid(BaseActivity):
             f"Loading data from Druid: {datasource} with query: {query}"
         )
 
-        places = Table(datasource, MetaData(), autoload_with=self.engine)
+        places = Table(datasource, MetaData(), autoload_with=self.druid_engine)
         stmt = select(places).where(text(query))
 
-        result = pd.read_sql(stmt, self.engine)
+        result = pd.read_sql(stmt, self.druid_engine)
 
         result["inserted_at"] = pd.to_datetime(result["__time"]).dt.strftime(
             "%Y-%m-%d %H:%M:%S.%f")
diff --git a/values.yaml b/values.yaml
index 884ccf7..6686b55 100644
--- a/values.yaml
+++ b/values.yaml
@@ -185,7 +185,7 @@ env:
   - name: DRUID_HOST
     value: "druid-router.druid.svc.cluster.local"
   - name: DRUID_PORT
-    value: "8081"
+    value: "8888"
 
 ssh:
   enabled: true