stawros/karl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

chore: WoodpeckerRunner logs

Browse source
This commit is contained in:
Piotr Dec 2026-06-11 14:11:15 +02:00
parent bb258efa39
commit d220ac1963
Signed by: stawros
GPG key ID: 74B18A3F0F1E99C0
1 changed files with 7 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/karl/core/woodpecker.py
View file

@ -32,6 +32,7 @@ class WoodpeckerRunner(Thread):
self._bus = bus self._bus = bus
self._event: WoodpeckerEvent | None = None self._event: WoodpeckerEvent | None = None
self._root = get_settings().git.path self._root = get_settings().git.path
self.thread_logger = logging.getLogger(self.__class__.name)
def process_event(self, event: WoodpeckerEvent): def process_event(self, event: WoodpeckerEvent):
self._event = event self._event = event
@ -42,13 +43,15 @@ class WoodpeckerRunner(Thread):
await self._bus.dispatch(r) await self._bus.dispatch(r)
result = RunnerResult() result = RunnerResult()
self.thread_logger.info("Runner started")
try: try:
services = self.get_service(self._event.files) services = self.get_service(self._event.files)
if len(services) == 0: if len(services) == 0:
logger.info("No service found.") self.thread_logger.info("No service found.")
result.success = True result.success = True
else: else:
self._git.checkout(self._event.commit) self._git.checkout(self._event.commit)
self.thread_logger.info(f"Checked out successfully at {self._event.commit}")
paths = [] paths = []
for service in services: for service in services:
service_path = f"{self._root}/compose/{service}/docker-compose.yml" service_path = f"{self._root}/compose/{service}/docker-compose.yml"
@ -56,8 +59,10 @@ class WoodpeckerRunner(Thread):
if file.__contains__('.mo.'): if file.__contains__('.mo.'):
self._mo.process(Path(f"{self._root}/{file}").absolute()) self._mo.process(Path(f"{self._root}/{file}").absolute())
paths.append(service_path) paths.append(service_path)
self.thread_logger.info(f"{len(paths)} paths set")
for service_path in paths: for service_path in paths:
self._docker.reload(Path(service_path).absolute()) self._docker.reload(Path(service_path).absolute())
self.thread_logger.info("Reloaded all services")
result.success = True result.success = True
except Exception as e: except Exception as e:
result.throwable = e result.throwable = e
@ -92,7 +97,7 @@ class Woodpecker:
logger.info("Woodpecker initialized.") logger.info("Woodpecker initialized.")
async def on_ci_event(self, event: WoodpeckerEvent): 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: with self._lock:
logger.debug("Lock acquired [on-ci-event]") logger.debug("Lock acquired [on-ci-event]")
if len(self._pending) > 0 or self._runner is not None: if len(self._pending) > 0 or self._runner is not None: