From d61e861b0da1647974e617e1633c429c307789be Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 4 Apr 2016 18:57:32 -0700 Subject: Consolidate conn fixture definitions --- test/test_coordinator.py | 13 ------------- 1 file changed, 13 deletions(-) (limited to 'test/test_coordinator.py') 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 ( @@ -22,18 +21,6 @@ from kafka.protocol.metadata import MetadataResponse 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()) -- cgit v1.2.1