@@ -104,7 +104,7 @@ def get_queue_status(self, user=None):
104
104
else :
105
105
return df [df ["user" ] == user ]
106
106
107
- def get_job_from_remote (self , working_directory , delete_remote = False ):
107
+ def get_job_from_remote (self , working_directory ):
108
108
"""
109
109
Get the results of the calculation - this is necessary when the calculation was executed on a remote host.
110
110
"""
@@ -130,10 +130,10 @@ def get_job_from_remote(self, working_directory, delete_remote=False):
130
130
)
131
131
file_dict [local_file ] = f
132
132
self ._transfer_files (file_dict = file_dict , sftp = None , transfer_back = True )
133
- if delete_remote :
133
+ if self . _ssh_delete_file_on_remote :
134
134
self ._execute_remote_command (command = "rm -r " + remote_working_directory )
135
135
136
- def transfer_file (self , file , transfer_back = False , delete_remote = False ):
136
+ def transfer_file (self , file , transfer_back = False ):
137
137
working_directory = os .path .abspath (os .path .expanduser (file ))
138
138
remote_working_directory = self ._get_remote_working_dir (
139
139
working_directory = working_directory
@@ -144,7 +144,7 @@ def transfer_file(self, file, transfer_back=False, delete_remote=False):
144
144
sftp = None ,
145
145
transfer_back = transfer_back ,
146
146
)
147
- if delete_remote and transfer_back :
147
+ if self . _ssh_delete_file_on_remote and transfer_back :
148
148
self ._execute_remote_command (command = "rm " + remote_working_directory )
149
149
150
150
def __del__ (self ):
0 commit comments