summaryrefslogtreecommitdiff
path: root/test/test_coordinator.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-04-04 18:57:32 -0700
committerDana Powers <dana.powers@gmail.com>2016-04-07 09:49:05 -0700
commitd61e861b0da1647974e617e1633c429c307789be (patch)
treedad1382251212e88666baa20c7ec8d279487fa48 /test/test_coordinator.py
parent931373478e30a9d44b89fad6491136222441e929 (diff)
downloadkafka-python-d61e861b0da1647974e617e1633c429c307789be.tar.gz
Consolidate conn fixture definitions
Diffstat (limited to 'test/test_coordinator.py')
-rw-r--r--test/test_coordinator.py13
1 files changed, 0 insertions, 13 deletions
diff --git a/test/test_coordinator.py b/test/test_coordinator.py
index 629b72f..399609d 100644
--- a/test/test_coordinator.py
+++ b/test/test_coordinator.py
@@ -12,7 +12,6 @@ from kafka.coordinator.assignors.roundrobin import RoundRobinPartitionAssignor
from kafka.coordinator.consumer import ConsumerCoordinator
from kafka.coordinator.protocol import (
ConsumerProtocolMemberMetadata, ConsumerProtocolMemberAssignment)
-from kafka.conn import ConnectionStates
import kafka.errors as Errors
from kafka.future import Future
from kafka.protocol.commit import (
@@ -23,18 +22,6 @@ from kafka.util import WeakMethod
@pytest.fixture
-def conn(mocker):
- conn = mocker.patch('kafka.client_async.BrokerConnection')
- conn.return_value = conn
- conn.state = ConnectionStates.CONNECTED
- conn.send.return_value = Future().success(
- MetadataResponse[0](
- [(0, 'foo', 12), (1, 'bar', 34)], # brokers
- [])) # topics
- return conn
-
-
-@pytest.fixture
def coordinator(conn):
return ConsumerCoordinator(KafkaClient(), SubscriptionState())