REST API: get_execution_livelog (mongoDB-only)

mupif · Sep 26, 2023 · 6e44c7c · 6e44c7c
1 parent d8abccb
commit 6e44c7c
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/mupifDB/api/main.py b/mupifDB/api/main.py
@@ -280,6 +280,16 @@ def get_execution_outputs(uid: str):
             return inp.get('DataSet', None)
     return None
 
+@app.get("/executions/{uid}/livelog/{num}", tags=["Executions"])
+def get_execution_livelog(uid: str, num: int):
+    if (rec:=db.WorkflowExecutions.find_one({"_id": bson.objectid.ObjectId(uid)})) and (uri:=rec.get('loggerURI',None)):
+        proxy=Pyro5.api.Proxy(uri)
+        proxy._pyroTimeout=5
+        ll=proxy.tail(num,raw=True)
+        if isinstance(ll,dict): ll=serpent.tobytes(ll)
+        ll=pickle.loads(ll)
+        return [fmt.format(rec) for rec in ll]
+
 
 def get_execution_io_item(uid, name, obj_id, inout):
     we = db.WorkflowExecutions.find_one({"_id": bson.objectid.ObjectId(uid)})