Commit b04096b6 authored by Jérome Perrin's avatar Jérome Perrin

repair WIP stat on queues

parent 165a59fc
...@@ -375,6 +375,9 @@ class Simulation(object): ...@@ -375,6 +375,9 @@ class Simulation(object):
"start": 1, "start": 1,
"stop": -1 "stop": -1
} }
for node in data["nodes"].values():
if node['_class'] in ('Dream.Queue', ):
node['gatherWipStat'] = 1
return data return data
def run(self, data): def run(self, data):
......
...@@ -260,7 +260,7 @@ from Queue import Queue ...@@ -260,7 +260,7 @@ from Queue import Queue
def countQueueMetrics(argumentDict={}): def countQueueMetrics(argumentDict={}):
for obj in G.ObjList: for obj in G.ObjList:
if isinstance(obj, Queue): if isinstance(obj, Queue):
obj.wip_stat_list.append((G.env.now, len(obj.Res.activeQ))) obj.wipStatList.append((G.env.now, len(obj.Res.users)))
# ======================================================================= # =======================================================================
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment