fix: Absolute path fix
This commit is contained in:
parent
bc592a2c6c
commit
3224f8cfca
1 changed files with 3 additions and 1 deletions
|
|
@ -6,6 +6,7 @@ from typing import Annotated
|
|||
from bubus import EventBus
|
||||
from injectable import injectable, autowired, Autowired
|
||||
|
||||
from karl import get_settings
|
||||
from model.webhook import ReloadEvent, WoodpeckerEvent
|
||||
from services import GitService
|
||||
|
||||
|
|
@ -20,13 +21,14 @@ class ReloadService:
|
|||
self._bus = bus
|
||||
self._git = GitService()
|
||||
bus.on(ReloadEvent, self.on_reload)
|
||||
self.root_path = get_settings().git.path
|
||||
logger.info("ReloadService initialized.")
|
||||
|
||||
async def on_reload(self, event: ReloadEvent):
|
||||
try:
|
||||
logger.info(f"Received ReloadEvent: {event.service}")
|
||||
head = self._git.get_head()
|
||||
file_path = Path(f"files/{event.service}")
|
||||
file_path = Path(self.root_path) / f"files/{event.service}"
|
||||
if not file_path.exists():
|
||||
raise Exception(f"Service {event.service} not found: {file_path.absolute()} does not exist.")
|
||||
logger.debug(f"Found service files at {file_path}: {', '.join([str(f) for f in list(file_path.iterdir())])}")
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue