diff --git a/backend/scripts/ztplot.py b/backend/scripts/ztplot.py index 5b301226fbbca0f8700046007237cd7e1dde9f8c..7628c7ddab795dc15b37c888d8269fb65dcca5c2 100755 --- a/backend/scripts/ztplot.py +++ b/backend/scripts/ztplot.py @@ -20,7 +20,7 @@ from __future__ import division import km3pipe.style from km3modules.plot import ztplot -from km3modules.common import LocalDBService +from km3modules.common import LocalDBService, MemoryObserver from km3modules.communication import ELOGService from km3io.tools import is_3dmuon, is_3dshower, is_mxshower import km3db @@ -287,12 +287,13 @@ def main(): ligier_port = int(args['-p']) pipe = kp.Pipeline() + pipe.attach(MemoryObserver, every=1000) pipe.attach(LocalDBService, thread_safety=False) pipe.attach(ELOGService) pipe.attach(kp.io.ch.CHPump, host=ligier_ip, port=ligier_port, - tags='IO_EVT, IO_SUM', + tags='IO_EVT', timeout=60 * 60 * 24 * 7, max_queue=2000) pipe.attach(kp.io.daq.DAQProcessor)