@@ 119,7 119,7 @@ def heartbeat(platform, archs):
try:
status = GET("/heartbeat")
except:
- print("Heartbeat document not present")
+ time.sleep(15)
time_now = time.time() * 1000.0
@@ 136,8 136,7 @@ def heartbeat(platform, archs):
PUT("/heartbeat/", status)
return
except:
- print(status)
- print("Heartbeat update conflict")
+ time.sleep(5)
db_seq = "now"
@@ 210,8 209,6 @@ while True:
for file in files:
zip_handle.write(os.path.join(root, file), arcname = file)
-
-
job["status"] = "success"
job["url"] = "job/" + job_id + "/" + zip_path
@@ 228,6 225,10 @@ while True:
except ValueError as ve:
job["status"] = "failure"
job["log"] = ve.message
+ except:
+ job["status"] = "failure"
+ job["log"] = traceback.format_exc()
+ print(json.dumps(job))
job["_rev"] = claim["rev"]