From e4b04e41986a49985325d2a86902f6691fb200e9 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 17 Apr 2026 11:40:23 -0400 Subject: [PATCH] Fix mistake in exception handling --- confluent_server/confluent/collective/manager.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index 290922a1..4dfc915a 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -671,12 +671,15 @@ async def handle_connection(connection, cert, request, local=False): else: connection.write(cfgdata) await connection.drain() - finally: + except Exception as e: + log.log({'error': 'Error sending initial configuration data: {0}'.format(e), + 'subsystem': 'collective'}) try: await tlvdata.close(connection) except Exception as e: log.log({'info': 'Ignoring non-fatal error while closing collective connection: {0}'.format(e), 'subsystem': 'collective'}) + raise #tlvdata.send(connection, {'tenants': 0}) # skip the tenants for now, # so far unused anyway #connection.settimeout(90)