summaryrefslogtreecommitdiff
path: root/test/test_client_integration.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2014-08-25 10:15:16 -0700
committerDana Powers <dana.powers@rd.io>2014-08-25 12:54:54 -0700
commite151529078d53deca6254dee5b80e41e01226a7f (patch)
tree488ff0fb3a2ed26f52aa9f4b471ff3ff7060a938 /test/test_client_integration.py
parentd73d1690b16ea86a9fd51056f4d149f54a4dd8f0 (diff)
downloadkafka-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.py8
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")