We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 18233e1 commit dde46a6Copy full SHA for dde46a6
test/integ/conftest.py
@@ -41,10 +41,11 @@
41
42
logger = getLogger(__name__)
43
44
+
45
def _get_worker_specific_schema():
46
"""Generate worker-specific schema name for parallel test execution."""
47
base_uuid = str(uuid.uuid4()).replace("-", "_")
-
48
49
# Check if running in pytest-xdist parallel mode
50
worker_id = os.getenv("PYTEST_XDIST_WORKER")
51
if worker_id:
@@ -61,8 +62,10 @@ def _get_worker_specific_schema():
61
62
else:
63
return f"python_connector_tests_{base_uuid}"
64
65
66
TEST_SCHEMA = _get_worker_specific_schema()
67
68
69
if TEST_USING_VENDORED_ARROW:
70
snowflake.connector.cursor.NANOARR_USAGE = (
71
snowflake.connector.cursor.NanoarrowUsage.DISABLE_NANOARROW
0 commit comments