From 604381348abc23d2498cb7f813cc941ae539dc4b Mon Sep 17 00:00:00 2001 From: Piotr Dec Date: Tue, 14 Apr 2026 01:48:42 +0200 Subject: [PATCH] fix: logging in reload --- src/karl/services/reload.py | 34 +++++++++++++++++++--------------- 1 file changed, 19 insertions(+), 15 deletions(-) diff --git a/src/karl/services/reload.py b/src/karl/services/reload.py index 28997aa..c28b8be 100644 --- a/src/karl/services/reload.py +++ b/src/karl/services/reload.py @@ -1,3 +1,4 @@ +import logging from datetime import datetime from typing import Annotated @@ -7,23 +8,26 @@ from injectable import injectable, autowired, Autowired from model.webhook import ReloadEvent, WoodpeckerEvent from services import GitService +logger = logging.getLogger(__name__) + @injectable(singleton=True) class ReloadService: - @autowired - def __init__(self, bus: Annotated[EventBus, Autowired]): - self._bus = bus - self._bus.on(ReloadEvent, self.on_reload) - self._git = GitService() + @autowired + def __init__(self, bus: Annotated[EventBus, Autowired]): + self._bus = bus + self._bus.on(ReloadEvent, self.on_reload) + self._git = GitService() - def on_reload(self, event: ReloadEvent): - head = self._git.get_head() - self._bus.dispatch(WoodpeckerEvent( - _id=-1, - commit=head.sha, - ref=head.branch, - message=f"Manual reload of {event.service}", - started=int(datetime.now().timestamp()), - files=[f"compose/{event.service}/docker-compose.yml"] - )) + async def on_reload(self, event: ReloadEvent): + logger.info(f"Received ReloadEvent: {event.service}") + head = self._git.get_head() + await self._bus.dispatch(WoodpeckerEvent( + _id=-1, + commit=head.sha, + ref=head.branch, + message=f"Manual reload of {event.service}", + started=int(datetime.now().timestamp()), + files=[f"compose/{event.service}/docker-compose.yml"] + ))