Skip to content

Commit af3a57e

Browse files
committed
Set host and port in ExternalService test fixture
So we can run tests against an already running Kafka instance KAFKA_URI=tcp://localhost:9092 python -m test.test_integration
1 parent 33cde52 commit af3a57e

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

test/fixtures.py

+2
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,8 @@ def render_template(source_file, target_file, binding):
7474
class ExternalService(object):
7575
def __init__(self, host, port):
7676
print("Using already running service at %s:%d" % (host, port))
77+
self.host = host
78+
self.port = port
7779

7880
def open(self):
7981
pass

0 commit comments

Comments
 (0)