From aa9b7ea4cae8c7b39a083f000185a2cf685a7995 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Mon, 24 Aug 2026 16:52:13 -0400 Subject: [PATCH] Yield cooperatively during nodelist change --- confluent_server/confluent/discovery/core.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/confluent_server/confluent/discovery/core.py b/confluent_server/confluent/discovery/core.py index 642e6827..e3a3e1f1 100644 --- a/confluent_server/confluent/discovery/core.py +++ b/confluent_server/confluent/discovery/core.py @@ -700,6 +700,7 @@ async def _recheck_nodes_backend(nodeattribs, configmanager): macmap.vintage = 0 # expire current mac map data, in case # the attributes changed impacted the result for node in nodeattribs: + await asyncio.sleep(0) if node in known_nodes: for somemac in known_nodes[node]: unknown_info[somemac] = known_nodes[node][somemac] @@ -707,6 +708,7 @@ async def _recheck_nodes_backend(nodeattribs, configmanager): # Now we go through ones we did not find earlier for mac in list(unknown_info): try: + await asyncio.sleep(0) await _recheck_single_unknown(configmanager, mac) except Exception: traceback.print_exc()