diff --git a/tests/end_to_end/target_snowflake/tap_mariadb/test_resync_mariadb_to_sf_table_size_check.py b/tests/end_to_end/target_snowflake/tap_mariadb/test_resync_mariadb_to_sf_table_size_check.py index 9319db19a..7bdae39f6 100644 --- a/tests/end_to_end/target_snowflake/tap_mariadb/test_resync_mariadb_to_sf_table_size_check.py +++ b/tests/end_to_end/target_snowflake/tap_mariadb/test_resync_mariadb_to_sf_table_size_check.py @@ -14,9 +14,7 @@ def _create_ppw_config_file(table_mb): config_file.write('allowed_resync_max_size:\n') config_file.write(f' table_mb: {table_mb}\n') - [return_code, stdout, stderr] = tasks.run_command(f'pipelinewise import_config --dir {TEST_PROJECTS_DIR_PATH}') - print(stdout) - print(stderr) + [return_code, _, _] = tasks.run_command(f'pipelinewise import_config --dir {TEST_PROJECTS_DIR_PATH}') assert return_code == 0 @@ -42,12 +40,6 @@ def test_resync_mariadb_to_sf_if_table_size_greater_than_limit(self): # pylint: [return_code, _, _] = tasks.run_command(command) - with open(f'{CONFIG_DIR}/config.json', 'r', encoding='utf-8') as config_file: - aa = config_file.readlines() - for line in aa: - print(line) - - assert return_code == 1 def test_resync_mariadb_to_sf_if_table_size_less_than_limit(self): # pylint: disable = no-self-use diff --git a/tests/end_to_end/target_snowflake/tap_postgres/test_resync_pg_to_sf_table_size_check.py b/tests/end_to_end/target_snowflake/tap_postgres/test_resync_pg_to_sf_table_size_check.py index 0d184ede8..f3f4fff1c 100644 --- a/tests/end_to_end/target_snowflake/tap_postgres/test_resync_pg_to_sf_table_size_check.py +++ b/tests/end_to_end/target_snowflake/tap_postgres/test_resync_pg_to_sf_table_size_check.py @@ -14,9 +14,8 @@ def _create_ppw_config_file(table_mb): config_file.write('allowed_resync_max_size:\n') config_file.write(f' table_mb: {table_mb}\n') - [return_code, stdout, stderr] = tasks.run_command(f'pipelinewise import_config --dir {TEST_PROJECTS_DIR_PATH}') - print(stdout) - print(stderr) + [return_code, _, _] = tasks.run_command(f'pipelinewise import_config --dir {TEST_PROJECTS_DIR_PATH}') + assert return_code == 0 @@ -41,10 +40,6 @@ def test_resync_pg_to_sf_if_table_size_greater_than_limit(self): # pylint: dis command = f'pipelinewise sync_tables --tap {TAP_ID} --target {TARGET_ID}' [return_code, _, _] = tasks.run_command(command) - with open(f'{CONFIG_DIR}/config.json', 'r', encoding='utf-8') as config_file: - aa = config_file.readlines() - for line in aa: - print(line) assert return_code == 1