Skip to content
Snippets Groups Projects
Commit 2f4bdcf3 authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

Task #8887: only update stop times from otdb for pipelines

parent 0bbcd924
Branches
Tags
No related merge requests found
...@@ -139,7 +139,7 @@ class OTDBtoRATaskStatusPropagator(OTDBBusListener): ...@@ -139,7 +139,7 @@ class OTDBtoRATaskStatusPropagator(OTDBBusListener):
def _updateStopTime(self, treeId): def _updateStopTime(self, treeId):
radb_task = self.radb.getTask(otdb_id=treeId) radb_task = self.radb.getTask(otdb_id=treeId)
if radb_task: if radb_task and radb_task['type'] == 'pipeline':
otdb_task = self.otdb.taskGetTreeInfo(otdb_id=treeId) 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']): if otdb_task and (otdb_task['starttime'] != radb_task['starttime'] or otdb_task['stoptime'] != radb_task['endtime']):
new_endtime = otdb_task['stoptime'] new_endtime = otdb_task['stoptime']
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment