fix: put await bug

main
Malar Invention 2025-01-12 18:58:39 +05:30
parent 5832314a19
commit 69a595e708
1 changed files with 1 additions and 1 deletions

View File

@ -130,7 +130,7 @@ async def watch_services(v1, external_ips_update_queue):
# and putting back the final one when it runs empty
external_ips = await external_ips_update_queue.get()
if external_ips_update_queue.empty():
external_ips_update_queue.put(external_ips)
await external_ips_update_queue.put(external_ips)
break
logger.debug(f"Retrieved external IPs: {external_ips}")
await update_service_annotation(v1, service, external_ips)