File tree 1 file changed +5
-2
lines changed
1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -447,7 +447,7 @@ async def kill(self, iens: int) -> None:
447
447
448
448
async def kill_all (self ) -> None :
449
449
logger .debug (
450
- f"Killing realizations { self ._iens2jobid . keys ( )} with LSF-id { self ._iens2jobid .values ()} "
450
+ f"Killing realizations { ' ' . join ( str ( i ) for i in self ._iens2jobid )} with LSF-id { ' ' . join ( str ( i ) for i in self ._iens2jobid .values () )} "
451
451
)
452
452
bkill_with_args : list [str ] = [
453
453
str (self ._bkill_cmd ),
@@ -463,7 +463,10 @@ async def kill_all(self) -> None:
463
463
retry_interval = self ._sleep_time_between_cmd_retries ,
464
464
return_on_msgs = (JOB_ALREADY_FINISHED_BKILL_MSG ),
465
465
)
466
-
466
+ logger .info ("Sending SIGKILL in 15 seconds from now!!!" )
467
+ logger .info (
468
+ f"sleep { self ._sleep_time_between_bkills } ; { self ._bkill_cmd } -s SIGKILL { ' ' .join (str (i ) for i in self ._iens2jobid .values ())} "
469
+ )
467
470
await asyncio .create_subprocess_shell (
468
471
f"sleep { self ._sleep_time_between_bkills } ; { self ._bkill_cmd } -s SIGKILL { ' ' .join (str (i ) for i in self ._iens2jobid .values ())} " ,
469
472
start_new_session = True ,
You can’t perform that action at this time.
0 commit comments