Skip to content

Commit 4e7652f

Browse files
committed
Update exec_download in dataprocess_wrapper
1 parent cdcf9ce commit 4e7652f

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

relecov_tools/dataprocess_wrapper.py

+5-5
Original file line numberDiff line numberDiff line change
@@ -73,12 +73,12 @@ def clean_module_params(self, module, params):
7373
return module_valid_params
7474

7575
def exec_download(self, download_params):
76-
download_manager = DownloadManager(**download_params)
7776
if "sftp_port" in download_params:
78-
download_manager.relecov_sftp.sftp_port = int(download_params["sftp_port"])
79-
print(
80-
f"✅ SFTP port assigned: {self.download_manager.relecov_sftp.sftp_port}"
81-
)
77+
sftp_port = download_params.pop("sftp_port", None)
78+
download_manager = DownloadManager(**download_params)
79+
if sftp_port is not None:
80+
download_manager.relecov_sftp.sftp_port = int(sftp_port)
81+
print(f"SFTP port assigned: {download_manager.relecov_sftp.sftp_port}")
8282
download_manager.execute_process()
8383
finished_folders = download_manager.finished_folders
8484
download_logs = self.wrapper_logsum.prepare_final_logs(

0 commit comments

Comments
 (0)