Fixed logging messages.

Author: pantierra

eoapi_notifier/sources/pgstac.py

@@ -488,9 +488,8 @@ async def start(self) -> None:
 
         correlation_mode = "with correlation" if self._correlator else "raw events only"
         self.logger.info(
-            "Starting pgSTAC source (%s): %s",
-            correlation_mode,
-            self.config.get_connection_info(),
+            f"Starting pgSTAC source ({correlation_mode}): "
+            f"{self.config.get_connection_info()}"
         )
 
         self.logger.debug("Step 1: Establishing database connection...")
@@ -559,10 +558,8 @@ async def _establish_connection(self) -> None:
             self._current_delay = self.config.reconnect_delay
 
             self.logger.info(
-                "✓ Connected to pgSTAC database at %s:%s/%s",
-                self.config.host,
-                self.config.port,
-                self.config.database,
+                f"✓ Connected to pgSTAC database at "
+                f"{self.config.host}:{self.config.port}/{self.config.database}"
             )
 
         except Exception as e:
@@ -613,7 +610,7 @@ async def _setup_listener(self) -> None:
             self.config.channel, self._handle_notification
         )
 
-        self.logger.info("✓ Listening on channel: %s", self.config.channel)
+        self.logger.info(f"✓ Listening on channel: {self.config.channel}")
 
     async def _cleanup_connection(self) -> None:
         """Clean up database connection and listener."""
@@ -703,7 +700,11 @@ async def _process_notifications(self) -> None:
                 )
 
     def _handle_notification(
-        self, connection: asyncpg.Connection, pid: int, channel: str, payload: str
+        self,
+        connection: asyncpg.Connection,
+        pid: int,
+        channel: str,
+        payload: str,
     ) -> None:
         """Handle incoming PostgreSQL notification."""
         self.logger.debug(
@@ -782,7 +783,9 @@ def _create_notification_event(self, payload: str) -> NotificationEvent | None:
 
         except (json.JSONDecodeError, KeyError) as e:
             self.logger.error(
-                "✗ Invalid notification payload: %s - payload was: %s", e, payload
+                "✗ Invalid notification payload: %s - payload was: %s",
+                e,
+                payload,
             )
             return None
 
@@ -796,7 +799,9 @@ async def _raw_event_stream(self) -> AsyncIterator[NotificationEvent]:
                 event = await asyncio.wait_for(self._event_queue.get(), timeout=1.0)
                 event_stream_count += 1
                 self.logger.debug(
-                    "Streaming event #%d from queue: %s", event_stream_count, event.id
+                    "Streaming event #%d from queue: %s",
+                    event_stream_count,
+                    event.id,
                 )
                 yield event
             except TimeoutError:

helm-chart/eoapi-notifier/templates/configmap.yaml

@@ -12,16 +12,7 @@ data:
     {{- range .Values.config.sources}}
       - type: {{.type}}
         config:
-          {{- if eq .type "pgstac"}}
-          # Connection details provided via environment variables
-          host: localhost
-          port: 5432
-          database: postgis
-          user: postgres
-          password: password
-          {{- else}}
           {{- toYaml .config | nindent 10}}
-          {{- end}}
     {{- end}}
 
     outputs: