Disable walltime for running jobs.

diff --git a/stat2pbs.py b/stat2pbs.py
index 14f5a4d..3eb9c8b 100755 (executable)
--- 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: