fix: take_over_counters

Signed-off-by: kostas <[email protected]>

Author: kostasrim

tests/dragonfly/replication_test.py

@@ -1246,7 +1246,10 @@ async def block_during_takeover():
         "Add a blocking command during takeover to make sure it doesn't block it."
         start = time.time()
         # The command should just be canceled
-        assert await c_blocking.execute_command("BLPOP BLOCKING_KEY1 BLOCKING_KEY2 100") is None
+        try:
+            assert await c_blocking.execute_command("BLPOP BLOCKING_KEY1 BLOCKING_KEY2 100") is None
+        except (redis.exceptions.ConnectionError, redis.exceptions.ResponseError) as e:
+            break
         # And it should happen in reasonable amount of time.
         assert time.time() - start < 10