@@ -45,7 +45,7 @@ def run_jobs(self,
45
45
mark_failure = False ,
46
46
outlog = 'log' ,
47
47
errlog = 'err' ):
48
- ratio_failure = self .mdata_resources .get ("ratio_failue " , 0 )
48
+ ratio_failure = self .mdata_resources .get ("ratio_failure " , 0 )
49
49
while True :
50
50
if self .check_all_dispatchers_finished (ratio_failure ):
51
51
self .clean ()
@@ -188,7 +188,7 @@ def make_dispatcher(self, ii):
188
188
189
189
190
190
# Base
191
- def check_dispatcher_status (self , ii , allow_failue = False ):
191
+ def check_dispatcher_status (self , ii , allow_failure = False ):
192
192
'''catch running dispatcher exception
193
193
if no exception occured, check finished'''
194
194
if self .dispatcher_list [ii ]["dispatcher_status" ] == "running" :
@@ -198,7 +198,7 @@ def check_dispatcher_status(self, ii, allow_failue=False):
198
198
clean = self .mdata_resources .get ("clean" , False )
199
199
try :
200
200
# avoid raising ssh exception in download proceess
201
- finished = self .dispatcher_list [ii ]["dispatcher" ].all_finished (self .dispatcher_list [ii ]["entity" ].job_handler , allow_failue , clean )
201
+ finished = self .dispatcher_list [ii ]["dispatcher" ].all_finished (self .dispatcher_list [ii ]["entity" ].job_handler , allow_failure , clean )
202
202
if finished :
203
203
self .dispatcher_list [ii ]["dispatcher_status" ] = "finished"
204
204
except Exception :
0 commit comments