From 2b91c9d69735c5b42fc916e161bb6e97753c2497 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Franti=C5=A1ek=20Dvo=C5=99=C3=A1k?= Date: Thu, 5 Mar 2015 18:12:12 +0100 Subject: [PATCH] Disable walltime for running jobs. --- stat2pbs.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/stat2pbs.py b/stat2pbs.py index 14f5a4d..3eb9c8b 100755 --- a/stat2pbs.py +++ b/stat2pbs.py @@ -80,9 +80,12 @@ def gen_string(job): cput = time.strftime('%H:%M:%S', time.gmtime(job['cpu_seconds'])) pbs_cput = ' resources_used.cput=%s' % cput - walltime = time.strftime('%H:%M:%S', time.gmtime((long(job['finish']) - long(job['start'])) / 1000)) + pbs_walltime = '' + if job['finish']: + walltime = time.strftime('%H:%M:%S', time.gmtime((long(job['finish']) - long(job['start'])) / 1000)) + pbs_walltime = ' resources_used.walltime=%s' % walltime - return '%s;%s;%s.%s;user=%s group=hadoop%s queue=%s%s%s%s start=%d end=%d owner=%s@%s%s%s%s resources_used.walltime=%s' % (log_time, status, job['id'], cluster_hostname, job['user'], pbs_name, job['queue'], pbs_submit, pbs_qtime, pbs_etime, int(job['start']) / 1000, int(job['finish']) / 1000, job['user'], realm, pbs_exec_host, pbs_exit_status, pbs_cput, walltime) + return '%s;%s;%s.%s;user=%s group=hadoop%s queue=%s%s%s%s start=%d end=%d owner=%s@%s%s%s%s%s' % (log_time, status, job['id'], cluster_hostname, job['user'], pbs_name, job['queue'], pbs_submit, pbs_qtime, pbs_etime, int(job['start']) / 1000, int(job['finish']) / 1000, job['user'], realm, pbs_exec_host, pbs_exit_status, pbs_cput, pbs_walltime) try: -- 1.8.2.3