fixed schema

transferwise · Jul 18, 2024 · fd8c119 · fd8c119
1 parent db1a084
commit fd8c119
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 16 deletions.
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
@@ -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
@@ -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