From be930fc0763633adac7898299ac731c8f25e380d Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 10 Oct 2018 16:30:28 -0400 Subject: [PATCH] Add missing subsystem marker from a collective log --- 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 09961698..9e82b509 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -101,7 +101,7 @@ def connect_to_leader(cert=None, name=None, leader=None): log.log({'info': 'Prospective leader {0} has inferior ' 'transaction count, becoming leader' - ''.format(leader)}) + ''.format(leader), 'subsystem': 'collective'}) return become_leader(remote) print(keydata['error']) return False @@ -360,7 +360,7 @@ def handle_connection(connection, cert, request, local=False): tlvdata.send(connection, {'error': 'Refusing to be assimilated by inferior' 'transaction count', - 'txcount': cfm._txcount}) + 'txcount': cfm._txcount,}) return eventlet.spawn_n(connect_to_leader, None, None, leader=connection.getpeername()[0])