fix: add logs for service watcher

main
Malar Invention 2025-01-12 18:12:14 +05:30
parent a1cf0467da
commit 59dd11f353
1 changed files with 5 additions and 0 deletions

View File

@ -122,8 +122,13 @@ async def watch_services(v1, external_ips_update_queue):
):
service = event["object"]
if event["type"] in {"ADDED", "MODIFIED"}:
logger.debug(
f"Processing event type: {event['type']} for service: {service.metadata.name}"
)
external_ips = await external_ips_update_queue.get()
logger.debug(f"Retrieved external IPs: {external_ips}")
await update_service_annotation(v1, service, external_ips)
logger.debug(f"Service updated: {service.metadata.name}")
except client.exceptions.ApiException as e:
logger.error(f"API Exception in watch_services: {e}")