update

Author: luoluoyuyu

.gitignore

@@ -37,3 +37,4 @@ python/**/target/
 # Integration test output
 tests/integration/target/
 tests/integration/.venv/
+tests/integration/install

tests/integration/Makefile

@@ -34,7 +34,7 @@ help:
 	@echo "  test    Setup Python env + run pytest (PYTEST_ARGS=...)"
 	@echo "  clean   Remove .venv and target/tests output"
 
-$(VENV)/.installed: requirements.txt $(PYTHON_ROOT)/functionstream-api/pyproject.toml $(PYTHON_ROOT)/functionstream-client/pyproject.toml
+install $(VENV)/.installed: requirements.txt $(PYTHON_ROOT)/functionstream-api/pyproject.toml $(PYTHON_ROOT)/functionstream-client/pyproject.toml
 	$(call log,ENV,Setting up Python virtual environment)
 	@test -d $(VENV) || python3 -m venv $(VENV)
 	@$(PIP) install --quiet --upgrade pip
@@ -44,7 +44,7 @@ $(VENV)/.installed: requirements.txt $(PYTHON_ROOT)/functionstream-api/pyproject
 	@touch $@
 	$(call success,Python environment ready)
 
-test: $(VENV)/.installed
+test: install
 	$(call log,TEST,Running integration tests)
 	@$(PY) -m pytest -v $(PYTEST_ARGS)
 	$(call success,All integration tests passed)

tests/integration/install

@@ -0,0 +1,19 @@
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+
+import sys
+from pathlib import Path
+
+import pytest
+
+sys.path.insert(0, str(Path(__file__).resolve().parents[2]))
+
+from framework import FunctionStreamInstance
+
+
+@pytest.fixture
+def fs_instance(request):
+    """Provides a fresh FunctionStreamInstance per test. Not started automatically."""
+    instance = FunctionStreamInstance(test_name=request.node.name)
+    yield instance
+    instance.kill()

tests/integration/test/conftest.py

@@ -0,0 +1,19 @@
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+
+import sys
+from pathlib import Path
+
+import pytest
+
+sys.path.insert(0, str(Path(__file__).resolve().parents[2]))
+
+from framework import FunctionStreamInstance
+
+
+@pytest.fixture
+def fs_instance(request):
+    """Provides a fresh FunctionStreamInstance per test. Not started automatically."""
+    instance = FunctionStreamInstance(test_name=request.node.name)
+    yield instance
+    instance.kill()