diff --git a/test/client.py b/test/dummy_client.py similarity index 100% rename from test/client.py rename to test/dummy_client.py diff --git a/test/fault_tolerance.py b/test/fault_tolerance.py index d109e62..6df8e63 100644 --- a/test/fault_tolerance.py +++ b/test/fault_tolerance.py @@ -10,7 +10,7 @@ from typing import List from threading import Lock -from client import pull, push, subscribe +from dummy_client import pull, push, subscribe TEST_SIZE = 1000 * 1000 KEY_SIZE = 8 diff --git a/test/order.py b/test/order.py index ddebf16..29e9750 100644 --- a/test/order.py +++ b/test/order.py @@ -5,7 +5,7 @@ import sys from typing import Dict, List -from client import pull, push, subscribe +from dummy_client import pull, push, subscribe TEST_SIZE = 1000 * 1000 KEY_SIZE = 8 diff --git a/test/scale.py b/test/scale.py index 93b7067..eb4c63f 100644 --- a/test/scale.py +++ b/test/scale.py @@ -4,7 +4,7 @@ ### press enter once more and see if you have a increase in throughput rate of the cluster import multiprocessing -from client import pull, push, subscribe +from dummy_client import pull, push, subscribe TEST_SIZE = 1000 * 1000 KEY_SIZE = 8 diff --git a/test/unit_test.py b/test/unit_test.py new file mode 100644 index 0000000..1fdb316 --- /dev/null +++ b/test/unit_test.py @@ -0,0 +1,13 @@ +import unittest + +from client.python import kafka_client as python_client +from client.go import client as go_client + + +# simple test which gets passed for all clients +class TestClient(unittest.TestCase): + def always_pass(self): + self.assertTrue(True) + +if __name__ == '__main__': + unittest.main()