From 606a3080465ef963ee302cf4692de92c13e8d9ac Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Mon, 14 Oct 2019 10:33:13 -0400 Subject: [PATCH] Fix quorum notification in mixed 2/3 collective --- confluent_server/confluent/config/configmanager.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index 1c2fab2f..3596a0ee 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -578,7 +578,7 @@ def relay_slaved_requests(name, listener, vers): lh = StreamHandler(listener) _hasquorum = len(cfgstreams) >= ( len(_cfgstore['collective']) // 2) - payload = cPickle.dumps({'quorum': _hasquorum}, protocol=vers) + payload = cPickle.dumps({'quorum': _hasquorum}, protocol=lowestver) for _ in pushes.starmap( _push_rpc, [(cfgstreams[s], payload) for s in cfgstreams]): @@ -622,7 +622,7 @@ def relay_slaved_requests(name, listener, vers): if cfgstreams: _hasquorum = len(cfgstreams) >= ( len(_cfgstore['collective']) // 2) - payload = cPickle.dumps({'quorum': _hasquorum}, protocol=vers) + payload = cPickle.dumps({'quorum': _hasquorum}, protocol=lowestver) for _ in pushes.starmap( _push_rpc, [(cfgstreams[s], payload) for s in cfgstreams]):