diff options
author | Dana Powers <dana.powers@rd.io> | 2014-08-25 10:15:16 -0700 |
---|---|---|
committer | Dana Powers <dana.powers@rd.io> | 2014-08-25 12:54:54 -0700 |
commit | e151529078d53deca6254dee5b80e41e01226a7f (patch) | |
tree | 488ff0fb3a2ed26f52aa9f4b471ff3ff7060a938 /test/test_client_integration.py | |
parent | d73d1690b16ea86a9fd51056f4d149f54a4dd8f0 (diff) | |
download | kafka-python-e151529078d53deca6254dee5b80e41e01226a7f.tar.gz |
Add pylint to tox.ini; test both kafka and test; default to error-checking only; fixup errors; skip kafka/queue.py
Diffstat (limited to 'test/test_client_integration.py')
-rw-r--r-- | test/test_client_integration.py | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/test/test_client_integration.py b/test/test_client_integration.py index 98f2473..b5bcb22 100644 --- a/test/test_client_integration.py +++ b/test/test_client_integration.py @@ -1,13 +1,11 @@ import os -import random import socket -import time import unittest2 import kafka from kafka.common import * -from fixtures import ZookeeperFixture, KafkaFixture -from testutil import * +from test.fixtures import ZookeeperFixture, KafkaFixture +from test.testutil import * class TestKafkaClientIntegration(KafkaIntegrationTestCase): @classmethod @@ -34,7 +32,7 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase): with Timer() as t: with self.assertRaises((socket.timeout, socket.error)): - conn = kafka.conn.KafkaConnection("localhost", server_port, 1.0) + kafka.conn.KafkaConnection("localhost", server_port, 1.0) self.assertGreaterEqual(t.interval, 1.0) @kafka_versions("all") |