Try to fix orphan processes

code/ARAX/ARAXQuery/ARAX_query.py

@@ -240,7 +240,7 @@ def query_return_message(self, query, mode='ARAX'):
                 'status': 'Running Async',
                 'message_id': None,
                 'message_code': 'Running',
-                'code_description': 'Query running via /asyncquery'
+                'code_description': 'Query running via /asyncquery (parent)'
             }
             query_tracker = ARAXQueryTracker()
             query_tracker.update_tracker_entry(self.response.job_id, attributes)
@@ -695,6 +695,10 @@ def execute_processing_plan(self,input_operations_dict, mode='ARAX'):
             #### and the child continues to work on the query, eventually to finish and exit()
             if mode == 'asynchronous':
                 callback = input_operations_dict['callback']
+                if callback.startswith('http://localhost'):
+                    response.error(f"ERROR: A callback to localhost ({callback}) does not work. Please specify a resolvable callback URL")
+                    return response
+
                 response.info(f"Everything seems in order to begin processing the query asynchronously. Processing will continue and Response will be posted to {callback}")
                 newpid = os.fork()
                 #### The parent returns to tell the caller that work will proceed
@@ -704,14 +708,19 @@ def execute_processing_plan(self,input_operations_dict, mode='ARAX'):
                     return response
                 #### The child continues
                 #### The child loses the MySQL connection of the parent, so need to reconnect
+                time.sleep(1)
                 response_cache.connect()
                 time.sleep(1)
+
+                child_pid = os.getpid()
+                response.debug(f"Child continues running. Child PID is {child_pid}. Record with alter_tracker_entry()")
                 attributes = {
-                    'pid': os.getpid(),
-                    'code_description': 'Query executing via /asyncquery'
+                    'pid': child_pid,
+                    'code_description': 'Query executing via /asyncquery (child)'
                 }
                 query_tracker = ARAXQueryTracker()
-                query_tracker.alter_tracker_entry(self.response.job_id, attributes)
+                alter_result = query_tracker.alter_tracker_entry(self.response.job_id, attributes)
+                response.debug(f"Child PID {child_pid} recorded with result {alter_result}")
 
 
             #### If there is already a KG with edges, recompute the qg_keys

code/ARAX/ARAXQuery/ARAX_query_tracker.py

@@ -221,26 +221,37 @@ def update_tracker_entry(self, tracker_id, attributes):
     #### Alter arbitray values in a tracker entry
     def alter_tracker_entry(self, tracker_id, attributes):
         if tracker_id is None:
-            return
+            return("ERROR: tracker_id is None")
 
         session = self.session
         if session is None:
-            return
+            return("ERROR: session is None")
+
+        return_value = ''
 
         tracker_entries = session.query(ARAXQuery).filter(ARAXQuery.query_id==tracker_id).all()
         if len(tracker_entries) > 0:
             tracker_entry = tracker_entries[0]
             for key, value in attributes.items():
                 setattr(tracker_entry, key, value)
+        else:
+            return_value += 'ERROR: No tracker_entries  '
 
         ongoing_tracker_entries = session.query(ARAXOngoingQuery).filter(ARAXOngoingQuery.query_id==tracker_id).all()
         if len(ongoing_tracker_entries) > 0:
             ongoing_tracker_entry = ongoing_tracker_entries[0]
             for key, value in attributes.items():
                 setattr(ongoing_tracker_entry, key, value)
+        else:
+            return_value += 'ERROR: No ongoing_tracker_entries  '
 
         session.commit()
 
+        if len(return_value) == 0:
+            return_value = 'OK'
+
+        return(return_value)
+
 
     ##################################################################################################
     def get_instance_info(self):