Task #9607: update observation stoptime on abort

SAS/ResourceAssignment/OTDBtoRATaskStatusPropagator/propagator.py

@@ -137,9 +137,12 @@ class OTDBtoRATaskStatusPropagator(OTDBBusListener):
     def onObservationCompleting(self, treeId, modificationTime):
         self._update_radb_task_status(treeId, 'completing')
 
-    def _updateStopTime(self, treeId):
+    def _updateStopTime(self, treeId, only_pipelines=False):
         radb_task = self.radb.getTask(otdb_id=treeId)
-        if radb_task and radb_task['type'] == 'pipeline':
+        if radb_task:
+            if only_pipelines and radb_task['type'] != 'pipeline':
+                return
+
             otdb_task = self.otdb.taskGetTreeInfo(otdb_id=treeId)
             if otdb_task and (otdb_task['starttime'] != radb_task['starttime'] or otdb_task['stoptime'] != radb_task['endtime']):
                 new_endtime = otdb_task['stoptime']
@@ -152,14 +155,13 @@ class OTDBtoRATaskStatusPropagator(OTDBBusListener):
 
         # otdb adjusts stoptime when finishing,
         # reflect that in radb for pipelines
-        self._updateStopTime(treeId)
+        self._updateStopTime(treeId, only_pipelines=True)
 
     def onObservationAborted(self, treeId, modificationTime):
         self._update_radb_task_status(treeId, 'aborted')
 
         # otdb adjusts stoptime when aborted,
-        # reflect that in radb for pipelines
-        self._updateStopTime(treeId)
+        self._updateStopTime(treeId, only_pipelines=False)
 
 def main():
     # Check the invocation arguments