Prule.daemon: Add exception traceback printing

prule/daemon/__main__.py

@@ -185,6 +185,7 @@ class JobQueue:
             with open(path, "r") as f:
                 data = json.load(f)
         except Exception as e:
+            traceback.print_exc()
             print(e)
             return False
         self.smallest_starttime = data["smallest_starttime"]
@@ -209,6 +210,7 @@ class JobQueue:
                 json.dump(data, f)
             print("Saved state to {}.".format(path))
         except Exception as e:
+            traceback.print_exc()
             print(e)
             print("Failed to save the state to {}:".format(path))
             print(data)
@@ -360,14 +362,15 @@ class CCCheckThread(threading.Thread):
                         signal.pthread_kill(config.main_tid, signal.SIGTERM) # shutdown
                     return None
                 except Exception as e:
+                    traceback.print_exc()
                     print(e)
                     #traceback.print_exc()
                     return None
             with self.stopCondition:
                 self.requestFuture = self.executor.submit(execRequest, req)
         except Exception as e:
-            print(e)
             traceback.print_exc()
+            print(e)
             return None
 
         #await self.requestTask
@@ -537,6 +540,7 @@ class PruleThread(threading.Thread):
                 return "wait"
             return None
         except Exception as e: # something went horribly wrong
+            traceback.print_exc()
             print("request_job_meta",e)
             return None
         return None
@@ -571,6 +575,7 @@ class PruleThread(threading.Thread):
                 return True
             return False
         except Exception as e: # something went horribly wrong
+            traceback.print_exc()
             print(e)
             return False
         return False
@@ -606,6 +611,7 @@ class PruleThread(threading.Thread):
                 return "wait"
             return False
         except Exception as e: # something went horribly wrong
+            traceback.print_exc()
             print(e)
             tdir.cleanup()
             return False
@@ -633,6 +639,7 @@ class PruleThread(threading.Thread):
                 signal.pthread_kill(config.main_tid, signal.SIGTERM) # shutdown
             return False
         except Exception as e: # something went horribly wrong
+            traceback.print_exc()
             print(e)
             return False
         return False
@@ -666,6 +673,7 @@ class PruleThread(threading.Thread):
                 result = json.loads(line)
                 break
             except Exception as e:
+                traceback.print_exc()
                 print(e)
                 if self.stopThread == True:
                     return (None, 0.0)
@@ -792,6 +800,7 @@ class PruleThread(threading.Thread):
                     result_json["evaluation_time"]
                 ))
             except Exception as e:
+                traceback.print_exc()
                 print(e)
                 print("Job {} process result {}".format(job.ccjobid, result_json))
 
@@ -831,6 +840,7 @@ class PruleThread(threading.Thread):
                 with prule.debug.Timing("prulethread.db_insert_result", "PRINT_TIMING" in config.config):
                     self.db_con.db_insert_result(job.ccjobid, result_json, job_meta, process_time, evaluated)
             except Exception as e:
+                traceback.print_exc()
                 print(e)
                 print("ERROR: db_insert_result failed for job ccid {}".format(job.ccjobid))
                 process_result = "failure-shutdown"
@@ -924,6 +934,7 @@ class PruleThread(threading.Thread):
                         with prule.debug.Timing("prulethread.db_insert_failure", "PRINT_TIMING" in config.config):
                             self.db_con.db_insert_failure(job.ccjobid)
                     except Exception as e:
+                        traceback.print_exc()
                         print(e)
                         print("ERROR: db_insert_failure failed for job ccid {}, requeue".format(job.ccjobid))
                         queue.add(job)