From 2f49ab602d247e72f830be8dc010bc704eb3d9b8 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Thu, 3 Sep 2026 13:42:43 -0400 Subject: [PATCH] Fix incorrect attribute on asyncio task --- confluent_server/confluent/collective/manager.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index 37c768e0..89ea87d9 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -565,7 +565,7 @@ async def handle_connection(connection, cert, request, local=False): {'error': 'Refusing, my name is better', 'txcount': cfm._txcount,}) return - if follower is not None and not follower.dead: + if follower is not None and not follower.done(): await tlvdata.send( connection, {'error': 'Already following, assimilate leader first', @@ -579,7 +579,7 @@ async def handle_connection(connection, cert, request, local=False): return cnn = tlvdata.get_socket(connection) if (currentleader == cnn.getpeername()[0] and - follower and not follower.dead): + follower and not follower.done()): # if we are happily following this leader already, don't stir # the pot await tlvdata.send(connection, {'status': 0})