From: František Dvořák <valtri@civ.zcu.cz>
Date: Thu, 5 Mar 2015 17:12:12 +0000 (+0100)
Subject: Disable walltime for running jobs.
X-Git-Url: http://scientific.zcu.cz/git/?a=commitdiff_plain;h=2b91c9d69735c5b42fc916e161bb6e97753c2497;p=hadoop-jobstat.git

Disable walltime for running jobs.
---

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: