Fix integration tests

Author: dolfinus

tests/test_integration/test_run_transfer/test_ftp.py

@@ -452,7 +452,8 @@ async def test_run_transfer_postgres_to_ftp_with_incremental_strategy(
     await run_transfer_and_verify(client, group_owner, postgres_to_ftp.id)
 
     downloader.run()
-    verify_file_name_template(list(Path.iterdir(tmp_path)), expected_extension)
+    file_names = [f.name for f in Path.iterdir(tmp_path) if f.is_file()]
+    verify_file_name_template(file_names, expected_extension)
 
     df_with_increment = reader.run()
     df_with_increment, second_transfer_df = cast_dataframe_types(df_with_increment, second_transfer_df)

tests/test_integration/test_run_transfer/test_ftps.py

@@ -317,7 +317,8 @@ async def test_run_transfer_postgres_to_ftps_with_incremental_strategy(
     await run_transfer_and_verify(client, group_owner, postgres_to_ftps.id)
 
     downloader.run()
-    verify_file_name_template(list(Path.iterdir(tmp_path)), expected_extension)
+    file_names = [f.name for f in Path.iterdir(tmp_path) if f.is_file()]
+    verify_file_name_template(file_names, expected_extension)
 
     df_with_increment = reader.run()
     df, second_transfer_df = cast_dataframe_types(df, second_transfer_df)

tests/test_integration/test_run_transfer/test_samba.py

@@ -317,7 +317,8 @@ async def test_run_transfer_postgres_to_samba_with_incremental_strategy(
     await run_transfer_and_verify(client, group_owner, postgres_to_samba.id)
 
     downloader.run()
-    verify_file_name_template(list(Path.iterdir(tmp_path)), expected_extension)
+    file_names = [f.name for f in Path.iterdir(tmp_path) if f.is_file()]
+    verify_file_name_template(file_names, expected_extension)
 
     df_with_increment = reader.run()
     df_with_increment, second_transfer_df = cast_dataframe_types(df_with_increment, second_transfer_df)

tests/test_integration/test_run_transfer/test_sftp.py

@@ -323,7 +323,8 @@ async def test_run_transfer_postgres_to_sftp_with_incremental_strategy(
     await run_transfer_and_verify(client, group_owner, postgres_to_sftp.id)
 
     downloader.run()
-    verify_file_name_template(list(Path.iterdir(tmp_path)), expected_extension)
+    file_names = [f.name for f in Path.iterdir(tmp_path) if f.is_file()]
+    verify_file_name_template(file_names, expected_extension)
 
     df_with_increment = reader.run()
     df_with_increment, second_transfer_df = cast_dataframe_types(df_with_increment, init_df)

tests/test_integration/test_run_transfer/test_webdav.py

@@ -316,7 +316,8 @@ async def test_run_transfer_postgres_to_webdav_with_incremental_strategy(
     await run_transfer_and_verify(client, group_owner, postgres_to_webdav.id)
 
     downloader.run()
-    verify_file_name_template(list(Path.iterdir(tmp_path)), expected_extension)
+    file_names = [f.name for f in Path.iterdir(tmp_path) if f.is_file()]
+    verify_file_name_template(file_names, expected_extension)
 
     df_with_increment = reader.run()
     df_with_increment, second_transfer_df = cast_dataframe_types(