Merge branch 'fix-scheduler' into 'enterprise'

fix(scheduler): prevent DisconnectedProducerError

See merge request dkinternal/observability/dataops-observability!34

Author: ci bot

deploy/charts/observability-app/Chart.yaml

@@ -2,7 +2,7 @@ apiVersion: v2
 name: dataops-observability-app
 type: application
 appVersion: "2.x.x"
-version: "2.2.0"
+version: "2.2.2"
 
 description: DataOps Observability
 home: https://datakitchen.io

deploy/charts/observability-app/values.yaml

@@ -133,9 +133,9 @@ autoscaling:
 
 serviceAccount:
   # Specifies whether a service account should be created
-  create: true
+  create: false
   # Annotations to add to the service account
   annotations: {}
   # The name of the service account to use.
   # If not set and create is true, a name is generated using the fullname template
-  name: ""
+  name: datakitchen-observability

deploy/charts/observability-services/Chart.yaml

@@ -2,7 +2,7 @@ apiVersion: v2
 name: dataops-observability-services
 type: application
 appVersion: "2.x.x"
-version: "2.0.0"
+version: "2.0.2"
 
 dependencies:
   - name: kafka

deploy/charts/observability-services/values.yaml

@@ -3,6 +3,9 @@ kafka:
     tag: 3.3.2-debian-12-r20
   enable: true
   fullnameOverride: kafka
+  serviceAccount:
+    create: true
+    name: datakitchen-observability
   # External access to kafka
   provisioning:
     enabled: true
@@ -24,6 +27,9 @@ mysql:
     # https://hub.docker.com/r/bitnami/mysql/tags
     tag: 8.0.36-debian-12-r9
   fullnameOverride: mysql
+  serviceAccount:
+    create: false
+    name: datakitchen-observability
   auth:
     username: observability
     database: datakitchen

scheduler/agent_check.py

@@ -90,5 +90,4 @@ def _send_agent_status_change_event(self, agent: Agent, new_status: AgentStatus)
             latest_event_timestamp=agent.latest_event_timestamp,
         )
 
-        with self.event_producer as producer:
-            producer.produce(self.kafka_topic, event)
+        self.event_producer.produce(self.kafka_topic, event)