Skip to content
Snippets Groups Projects
Commit 2965982a authored by Tamas Gal's avatar Tamas Gal :speech_balloon:
Browse files

Fix MSG dumper args

parent 7ce908ce
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Showing
with 3 additions and 4 deletions
scripts/msg_dumper.py
+ 3
− 4
View file @ 2965982a
...@@ -24,7 +24,7 @@ from km3pipe import Pipeline, Module ...@@ -24,7 +24,7 @@ from km3pipe import Pipeline, Module
from km3pipe.io import CHPump from km3pipe.io import CHPump
class LogIO(Module): class MSGDumper(Module):
def configure(self): def configure(self):
self.filename = self.get('filename', default='MSG.log') self.filename = self.get('filename', default='MSG.log')
self.fobj = open(os.path.abspath(self.filename)) self.fobj = open(os.path.abspath(self.filename))
...@@ -58,8 +58,7 @@ def main(): ...@@ -58,8 +58,7 @@ def main():
ligier_ip = args['-l'] ligier_ip = args['-l']
ligier_port = int(args['-p']) ligier_port = int(args['-p'])
logio_ip = args['-x'] filename = args['-f']
logio_port = int(args['-q'])
pipe = Pipeline() pipe = Pipeline()
pipe.attach( pipe.attach(
...@@ -69,7 +68,7 @@ def main(): ...@@ -69,7 +68,7 @@ def main():
tags='MSG', tags='MSG',
timeout=7 * 60 * 60 * 24, timeout=7 * 60 * 60 * 24,
max_queue=500) max_queue=500)
pipe.attach(LogIO, logio_ip=logio_ip, logio_port=logio_port) pipe.attach(MSGDumper, filename=filename)
pipe.drain() pipe.drain()
......
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