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

fix: annotations

Browse source
This commit is contained in:
Piotr Dec 2026-04-14 02:03:31 +02:00
parent 8f4dc486ac
commit 6ee6341a5e
Signed by: stawros
GPG key ID: 74B18A3F0F1E99C0
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/karl/api/v1.py
View file

@ -42,8 +42,8 @@ class APIv1:
await self.bus.dispatch(mapper.map(request)) await self.bus.dispatch(mapper.map(request))
return Response(status_code=201) return Response(status_code=201)
@router.post("/reload", summary="Manual service reload") @router.get("/reload", summary="Manual service reload")
async def reload(self, service: str = None): async def reload(self, service: str = None) -> Response:
if service is None: if service is None:
return Response(status_code=400) return Response(status_code=400)
await self.bus.dispatch(ReloadEvent(service=service)) await self.bus.dispatch(ReloadEvent(service=service))

2
src/karl/services/reload.py
View file

@ -17,8 +17,8 @@ class ReloadService:
@autowired @autowired
def __init__(self, bus: Annotated[EventBus, Autowired]): def __init__(self, bus: Annotated[EventBus, Autowired]):
self._bus = bus self._bus = bus
self._bus.on(ReloadEvent, self.on_reload)
self._git = GitService() self._git = GitService()
bus.on(ReloadEvent, self.on_reload)
async def on_reload(self, event: ReloadEvent): async def on_reload(self, event: ReloadEvent):
logger.info(f"Received ReloadEvent: {event.service}") logger.info(f"Received ReloadEvent: {event.service}")