diff --git a/dream/plugins/AddBatchStations.py b/dream/plugins/AddBatchStations.py index c6761550ae15682dffbe1cddb4976ccb25d7fc85..8af92bd2faaf7618c9749a29140f8164ea136c98 100644 --- a/dream/plugins/AddBatchStations.py +++ b/dream/plugins/AddBatchStations.py @@ -126,6 +126,10 @@ class AddBatchStations(plugin.InputPreparationPlugin): # add an edge from batchReassembly to destination self.addEdge(data, batchReassemblyId, destination) + # set all the Queue types to gether wip data + for node in data["graph"]["node"].values(): + if node['_class'] in ['Dream.Queue', 'Dream.LineClearance', 'Dream.RoutingQueue']: + node['gatherWipStat'] = 1 return data