diff --git a/node_external_ip_controller_async.py b/node_external_ip_controller_async.py
index 6b3c42e..1cbebbb 100644
--- a/node_external_ip_controller_async.py
+++ b/node_external_ip_controller_async.py
@@ -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)