diff options
author | Dana Powers <dana.powers@gmail.com> | 2016-04-04 18:57:32 -0700 |
---|---|---|
committer | Dana Powers <dana.powers@gmail.com> | 2016-04-07 09:49:05 -0700 |
commit | d61e861b0da1647974e617e1633c429c307789be (patch) | |
tree | dad1382251212e88666baa20c7ec8d279487fa48 /test/test_coordinator.py | |
parent | 931373478e30a9d44b89fad6491136222441e929 (diff) | |
download | kafka-python-d61e861b0da1647974e617e1633c429c307789be.tar.gz |
Consolidate conn fixture definitions
Diffstat (limited to 'test/test_coordinator.py')
-rw-r--r-- | test/test_coordinator.py | 13 |
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()) |