diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py
index d3c794da..7158e801 100644
--- a/confluent_server/confluent/config/configmanager.py
+++ b/confluent_server/confluent/config/configmanager.py
@@ -239,11 +239,11 @@ def exec_on_leader(function, *args):
 
 def exec_on_followers(fnname, *args):
     global _txcount
-    _txcount += 1
     if len(cfgstreams) < (len(_cfgstore['collective']) // 2):
         # the leader counts in addition to registered streams
         raise exc.DegradedCollective()
     pushes = eventlet.GreenPool()
+    _txcount += 1
     payload = cPickle.dumps({'function': fnname, 'args': args,
                              'txcount': _txcount})
     for res in pushes.starmap(