diff --git a/tests/integration_tests/with_db/fixtures/setup_database_fixture.py b/tests/integration_tests/with_db/fixtures/setup_database_fixture.py index ad83f43..85c8f61 100644 --- a/tests/integration_tests/with_db/fixtures/setup_database_fixture.py +++ b/tests/integration_tests/with_db/fixtures/setup_database_fixture.py @@ -8,6 +8,7 @@ BUCKETFS_CONNECTION_NAME = "TEST_AAF_BFS_CONN" SCHEMA_NAME = "TEST_INTEGRATION" + @pytest.fixture(scope="session") def pyexasol_connection(backend_aware_database_params) -> pyexasol.ExaConnection: return pyexasol.connect(**backend_aware_database_params) @@ -61,10 +62,10 @@ def database_with_slc( ) -> Tuple[str|None, str]: schema = _create_schema(pyexasol_connection) _deploy_scripts(pyexasol_connection) - bfs_conn = bucketfs_connection_factory(BUCKETFS_CONNECTION_NAME, "my-folder") + bucketfs_connection_factory(BUCKETFS_CONNECTION_NAME, "my-folder") # bfs_conn = _create_bucketfs_connection( # use_onprem, # pyexasol_connection, # backend_aware_bucketfs_params, # ) - return bfs_conn, schema + return BUCKETFS_CONNECTION_NAME, schema diff --git a/tests/integration_tests/with_db/test_query_loop_integration.py b/tests/integration_tests/with_db/test_query_loop_integration.py index e0e07be..935d6d2 100644 --- a/tests/integration_tests/with_db/test_query_loop_integration.py +++ b/tests/integration_tests/with_db/test_query_loop_integration.py @@ -56,11 +56,6 @@ def test_query_loop_integration_with_one_iteration_with_not_released_child_query # into its own session, for easier retrieval conn = pyexasol.connect(**backend_aware_database_params) - # conn = pyexasol.connect( - # dsn=db_params.address(), - # user=db_params.user, - # password=db_params.password) - # execute query loop bucketfs_connection_name, schema_name = database_with_slc args = json.dumps( @@ -97,11 +92,6 @@ def test_query_loop_integration_with_one_iteration_with_not_released_temporary_o # into its own session, for easier retrieval of the audit log conn = pyexasol.connect(**backend_aware_database_params) - # conn = pyexasol.connect( - # dsn=db_params.address(), - # user=db_params.user, - # password=db_params.password) - # execute query loop bucketfs_connection_name, schema_name = database_with_slc args = json.dumps( @@ -149,11 +139,6 @@ def test_query_loop_integration_with_two_iteration( # into its own session, for easier retrieval of the audit log conn = pyexasol.connect(**backend_aware_database_params) - # conn = pyexasol.connect( - # dsn=db_params.address(), - # user=db_params.user, - # password=db_params.password) - # execute query loop bucketfs_connection_name, schema_name = database_with_slc args = json.dumps(