From d220ac196396aad33c7b0def6a0ddf8062eebb6d Mon Sep 17 00:00:00 2001 From: Piotr Dec Date: Thu, 11 Jun 2026 14:11:15 +0200 Subject: [PATCH] chore: WoodpeckerRunner logs --- src/karl/core/woodpecker.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/karl/core/woodpecker.py b/src/karl/core/woodpecker.py index 3dc751e..83416a3 100644 --- a/src/karl/core/woodpecker.py +++ b/src/karl/core/woodpecker.py @@ -32,6 +32,7 @@ class WoodpeckerRunner(Thread): self._bus = bus self._event: WoodpeckerEvent | None = None self._root = get_settings().git.path + self.thread_logger = logging.getLogger(self.__class__.name) def process_event(self, event: WoodpeckerEvent): self._event = event @@ -42,13 +43,15 @@ class WoodpeckerRunner(Thread): await self._bus.dispatch(r) result = RunnerResult() + self.thread_logger.info("Runner started") try: services = self.get_service(self._event.files) if len(services) == 0: - logger.info("No service found.") + self.thread_logger.info("No service found.") result.success = True else: self._git.checkout(self._event.commit) + self.thread_logger.info(f"Checked out successfully at {self._event.commit}") paths = [] for service in services: service_path = f"{self._root}/compose/{service}/docker-compose.yml" @@ -56,8 +59,10 @@ class WoodpeckerRunner(Thread): if file.__contains__('.mo.'): self._mo.process(Path(f"{self._root}/{file}").absolute()) paths.append(service_path) + self.thread_logger.info(f"{len(paths)} paths set") for service_path in paths: self._docker.reload(Path(service_path).absolute()) + self.thread_logger.info("Reloaded all services") result.success = True except Exception as e: result.throwable = e @@ -92,7 +97,7 @@ class Woodpecker: logger.info("Woodpecker initialized.") async def on_ci_event(self, event: WoodpeckerEvent): - logger.debug(f"Received WoodpeckerEvent: {event.event_id}") + logger.info(f"Received WoodpeckerEvent: {event.event_id}") with self._lock: logger.debug("Lock acquired [on-ci-event]") if len(self._pending) > 0 or self._runner is not None: