Merge pull request #26 from vantage6/fix/updating_status_to_server

Updating the node status on the server when finishing a Task

Author: hcadavid

integration_poc/v6_k8s_node.py

@@ -537,7 +537,8 @@ def __poll_task_results(self):
                     {next_result}
                     *********************************************************************************  
                     """)
-                # notify socket channel of algorithm status change
+                
+                # notify other nodes about algorithm status change
                 self.socketIO.emit(
                     "algorithm_status_change",
                     data={
@@ -553,6 +554,25 @@ def __poll_task_results(self):
                 )
 
 
+                #Notify other nodes about algorithm status change
+                self.log.info(f"Sending result (run={next_result.run_id}) to the server!")
+
+                response = self.client.request(f"task/{next_result.task_id}")
+
+                init_org = response.get("init_org")            
+
+                self.client.run.patch(
+                    id_=next_result.run_id,
+                    data={
+                        "result": next_result.data,
+                        "log":next_result.logs[0],
+                        "status": next_result.status,
+                        "finished_at": datetime.datetime.now().isoformat(),
+                    },
+                    init_org_id=init_org.get("id"),
+                )
+
+
 
         except (KeyboardInterrupt, InterruptedError):
             self.log.info("Node is interrupted, shutting down...")