|
45 | 45 |
|
46 | 46 |
|
47 | 47 | # @pytest.fixture(scope="session", autouse=True)
|
48 |
| -# def list_catalog_config(request, datashare_db_kwargs): |
| 48 | +# def list_catalog_config(request, db_kwargs): |
49 | 49 | # filterwarnings("ignore", "DB-API extension cursor.next()")
|
50 | 50 | # filterwarnings("ignore", "DB-API extension cursor.__iter__()")
|
51 |
| -# with redshift_connector.connect(**datashare_db_kwargs) as con: |
| 51 | +# with redshift_connector.connect(**db_kwargs) as con: |
52 | 52 | # con.paramstyle = "format"
|
53 | 53 | # with con.cursor() as cursor:
|
54 | 54 | # for stmt in startup_stmts:
|
55 | 55 | # cursor.execute(stmt)
|
56 | 56 | #
|
57 | 57 | # def fin():
|
58 | 58 | # try:
|
59 |
| -# with redshift_connector.connect(**datashare_db_kwargs) as con: |
| 59 | +# with redshift_connector.connect(**db_kwargs) as con: |
60 | 60 | # with con.cursor() as cursor:
|
61 | 61 | # for stmt in shutdown_stmts:
|
62 | 62 | # cursor.execute(stmt)
|
@@ -138,11 +138,12 @@ def get_schemas_test_data() -> typing.List[typing.Tuple[bool, typing.Dict[str, t
|
138 | 138 | return result
|
139 | 139 |
|
140 | 140 |
|
| 141 | +@pytest.mark.skip(reason="manual") |
141 | 142 | @pytest.mark.parametrize("_input", get_schemas_test_data())
|
142 |
| -def test_get_schemas(mocker, _input, datashare_db_kwargs): |
| 143 | +def test_get_schemas(mocker, _input, db_kwargs): |
143 | 144 | database_metadata_current_db_only_val, _args = _input
|
144 |
| - datashare_db_kwargs["database_metadata_current_db_only"] = database_metadata_current_db_only_val |
145 |
| - with redshift_connector.connect(**datashare_db_kwargs) as conn: |
| 145 | + db_kwargs["database_metadata_current_db_only"] = database_metadata_current_db_only_val |
| 146 | + with redshift_connector.connect(**db_kwargs) as conn: |
146 | 147 | assert conn.is_single_database_metadata is database_metadata_current_db_only_val
|
147 | 148 |
|
148 | 149 | with conn.cursor() as cursor:
|
@@ -259,11 +260,12 @@ def get_tables_test_data() -> typing.List[typing.Tuple[bool, typing.Dict[str, ty
|
259 | 260 | return result
|
260 | 261 |
|
261 | 262 |
|
| 263 | +@pytest.mark.skip(reason="manual") |
262 | 264 | @pytest.mark.parametrize("_input", get_tables_test_data())
|
263 |
| -def test_get_tables(mocker, _input, datashare_db_kwargs): |
| 265 | +def test_get_tables(mocker, _input, db_kwargs): |
264 | 266 | database_metadata_current_db_only_val, _args = _input
|
265 |
| - datashare_db_kwargs["database_metadata_current_db_only"] = database_metadata_current_db_only_val |
266 |
| - with redshift_connector.connect(**datashare_db_kwargs) as conn: |
| 267 | + db_kwargs["database_metadata_current_db_only"] = database_metadata_current_db_only_val |
| 268 | + with redshift_connector.connect(**db_kwargs) as conn: |
267 | 269 | assert conn.is_single_database_metadata is database_metadata_current_db_only_val
|
268 | 270 |
|
269 | 271 | with conn.cursor() as cursor:
|
@@ -468,11 +470,12 @@ def get_columns_test_data() -> typing.List[typing.Tuple[bool, typing.Dict[str, t
|
468 | 470 | return result
|
469 | 471 |
|
470 | 472 |
|
| 473 | +@pytest.mark.skip(reason="manual") |
471 | 474 | @pytest.mark.parametrize("_input", get_columns_test_data())
|
472 |
| -def test_get_columns(mocker, _input, datashare_db_kwargs): |
| 475 | +def test_get_columns(mocker, _input, db_kwargs): |
473 | 476 | database_metadata_current_db_only_val, _args = _input
|
474 |
| - datashare_db_kwargs["database_metadata_current_db_only"] = database_metadata_current_db_only_val |
475 |
| - with redshift_connector.connect(**datashare_db_kwargs) as conn: |
| 477 | + db_kwargs["database_metadata_current_db_only"] = database_metadata_current_db_only_val |
| 478 | + with redshift_connector.connect(**db_kwargs) as conn: |
476 | 479 | assert conn.is_single_database_metadata is database_metadata_current_db_only_val
|
477 | 480 |
|
478 | 481 | with conn.cursor() as cursor:
|
|
0 commit comments