Mirrored_Repos/JBOPS
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add username argument for kill paused

Browse Source
This commit is contained in:
JonnyWong16 2018-08-13 21:15:31 -07:00
parent c413526ec3
commit ec07cebef9
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
killstream/kill_stream.py
View File

@ -189,7 +189,7 @@ def terminate_session(session_id, message, notifier=None, username=None):
return None return None
def terminate_long_pause(session_id, message, limit, interval, notify=None): def terminate_long_pause(session_id, message, limit, interval, notify=None, username=None):
"""Kills the session if it is paused for longer than <limit> seconds. """Kills the session if it is paused for longer than <limit> seconds.
Parameters Parameters
@ -226,7 +226,7 @@ def terminate_long_pause(session_id, message, limit, interval, notify=None):
if state == 'paused': if state == 'paused':
if checked_time >= limit: if checked_time >= limit:
terminate_session(session_id, message, notify) terminate_session(session_id, message, notify, username)
return return
else: else:
sleep(interval) sleep(interval)
@ -286,4 +286,4 @@ if __name__ == "__main__":
terminate_session(session_id, message, opts.notify, opts.username) terminate_session(session_id, message, opts.notify, opts.username)
elif opts.jbop == 'paused': elif opts.jbop == 'paused':
terminate_long_pause(opts.sessionId, message, opts.limit, terminate_long_pause(opts.sessionId, message, opts.limit,
opts.interval, opts.notify) opts.interval, opts.notify, opts.username)