From 86534b38ebb445390492d20b81457f7ef876b1c3 Mon Sep 17 00:00:00 2001
From: Jarrod Johnson <jjohnson2@lenovo.com>
Date: Thu, 16 Apr 2026 16:17:39 -0400
Subject: [PATCH] Correct some collective behavior

---
 confluent_server/confluent/collective/manager.py | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py
index ff55b413..38290e9f 100644
--- a/confluent_server/confluent/collective/manager.py
+++ b/confluent_server/confluent/collective/manager.py
@@ -134,7 +134,7 @@ async def connect_to_leader(cert=None, name=None, leader=None, remote=None, isre
                         {'info': 'Prospective leader {0} has redirected this '
                                  'member to {1}'.format(leader, keydata['leader']),
                          'subsystem': 'collective'})
-                    ldrc = cfm.get_collective_member_by_address(
+                    ldrc = await cfm.get_collective_member_by_address(
                         keydata['leader'])
                     if ldrc and ldrc['name'] == name:
                         raise Exception("Redirected to self")
@@ -276,7 +276,7 @@ async def connect_to_collective(cert, member, remote=None):
     if cert:
         fprint = cert
     else:
-        collent = cfm.get_collective_member_by_address(member)
+        collent = await cfm.get_collective_member_by_address(member)
         fprint = collent['fingerprint']
     cnn = remote[1].transport.get_extra_info('ssl_object')
     if not util.cert_matches(fprint, cnn.getpeercert(binary_form=True)):
@@ -320,7 +320,7 @@ async def handle_connection(connection, cert, request, local=False):
                                                       'system'}})
                 return
             if follower is not None:
-                linfo = cfm.get_collective_member_by_address(currentleader)
+                linfo = await cfm.get_collective_member_by_address(currentleader)
                 try:
                     _, remote = await create_connection(currentleader)
                     if isinstance(remote, Exception):
@@ -504,8 +504,8 @@ async def handle_connection(connection, cert, request, local=False):
             await cfm.add_collective_member(request['name'],
                                     connection[1].transport.get_extra_info('socket').getpeername()[0], fprint, role)
             myleader = await get_leader(connection)
-            ldrfprint = cfm.get_collective_member_by_address(
-                myleader)['fingerprint']
+            ldrfprint = (await cfm.get_collective_member_by_address(
+                myleader))['fingerprint']
             await tlvdata.send(connection,
                         {'collective': {'approval': myrsp,
                                         'fingerprint': ldrfprint,