Add LogForwarder to coordinator

canonical · Oct 8, 2024 · d0346fc · d0346fc
1 parent 030258d
commit d0346fc
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/pyproject.toml b/pyproject.toml
@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "cosl"
-version = "0.0.40"
+version = "0.0.41"
 authors = [
   { name="sed-i", email="[email protected]" },
 ]

diff --git a/src/cosl/coordinated_workers/coordinator.py b/src/cosl/coordinated_workers/coordinator.py
@@ -40,6 +40,8 @@
 )
 from cosl.helpers import check_libs_installed
 
+from lib.charms.loki_k8s.v1.loki_push_api import LogForwarder
+
 check_libs_installed(
     "charms.data_platform_libs.v0.s3",
     "charms.grafana_k8s.v0.grafana_source",
@@ -283,6 +285,7 @@ def __init__(
         )
 
         self._logging = LokiPushApiConsumer(self._charm, relation_name=self._endpoints["logging"])
+        self._log_forwarder = LogForwarder(self._charm, relation_name=self._endpoints["logging"])
 
         # Provide ability for this to be scraped by Prometheus using prometheus_scrape
         refresh_events = [self._charm.on.update_status, self.cluster.on.changed]