Return name of bucketfs connection in fixture database_with_slc

exasol · Sep 24, 2024 · 6501ac1 · 6501ac1
1 parent 67e50b9
commit 6501ac1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 17 deletions.
diff --git 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
@@ -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(