Revert all the changes made to PythonClient

quixio · Nov 7, 2023 · 05c7e3e · 05c7e3e
1 parent ca52315
commit 05c7e3e
Show file tree

Hide file tree

Showing 12 changed files with 21 additions and 145 deletions.
diff --git a/src/PythonClient/setup.py b/src/PythonClient/setup.py
@@ -83,7 +83,7 @@ def update_version_in_package(vers: str, fromvers: str = "local"):
         python_requires='>=3.6, <4',
         install_requires=[
             'pandas>=1.0.0,<2',
-            'Deprecated>=1.1,<2',
+            'Deprecated>=1.1,<2'
         ]
     )
 finally:

diff --git a/src/PythonClient/src/quixstreams/exceptions/__init__.py b/src/PythonClient/src/quixstreams/exceptions/__init__.py
diff --git a/src/PythonClient/src/requirements.txt b/src/PythonClient/src/requirements.txt
@@ -1 +1 @@
-pandas>=1.0.0,<2
+pandas>=1.0.0,<2
diff --git a/src/PythonClient/tests/LICENSE.pytest b/src/PythonClient/tests/LICENSE.pytest
diff --git a/src/PythonClient/tests/conftest.py b/src/PythonClient/tests/conftest.py
@@ -0,0 +1,8 @@
+import src.quixstreams as qx
+
+# Uncomment the next lines to enable low-level interop logs
+# It will also create a log file
+# from src.quixstreams.native.Python.InteropHelpers.InteropUtils import InteropUtils
+# InteropUtils.enable_debug()
+
+qx.Logging.update_factory(qx.LogLevel.Critical)
diff --git a/src/PythonClient/tests/pytest.ini b/src/PythonClient/tests/pytest.ini
diff --git a/src/PythonClient/tests/quixstreams/__init__.py b/src/PythonClient/tests/quixstreams/__init__.py
diff --git a/src/PythonClient/tests/quixstreams/conftest.py b/src/PythonClient/tests/quixstreams/conftest.py
diff --git a/src/PythonClient/tests/quixstreams/integrationtests/conftest.py b/src/PythonClient/tests/quixstreams/integrationtests/conftest.py
@@ -2,7 +2,8 @@
 
 from src import quixstreams as qx
 from src.quixstreams import AutoOffsetReset
-from tests.quixstreams.types import KafkaContainer
+from .containerhelper import ContainerHelper
+from .types import KafkaContainer
 
 
 @pytest.fixture()
@@ -15,7 +16,14 @@ def test_name(request: pytest.FixtureRequest) -> str:
     )
 
 
-
+@pytest.fixture(scope='session')
+def kafka_container() -> KafkaContainer:
+    kafka_container, broker_address, kafka_port, zookeeper_port = ContainerHelper.create_kafka_container()
+    print("Starting Kafka container")
+    ContainerHelper.start_kafka_container(kafka_container)
+    print("Started Kafka container")
+    yield KafkaContainer(broker_address=broker_address)
+    kafka_container.stop()
 
 
 @pytest.fixture()

diff --git a/src/PythonClient/tests/quixstreams/types.py → ...sts/quixstreams/integrationtests/types.py b/src/PythonClient/tests/quixstreams/types.py → ...sts/quixstreams/integrationtests/types.py
diff --git a/src/PythonClient/tests/quixstreams/logging.py b/src/PythonClient/tests/quixstreams/logging.py
diff --git a/src/PythonClient/tests/requirements.txt b/src/PythonClient/tests/requirements.txt
@@ -1,4 +1,4 @@
 testcontainers~=3.7.0
 pytest
 psutil
-numpy==1.24.3
+numpy==1.24.3