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

Fix parameters

parent 8da0a9bc
No related branches found
No related tags found
No related merge requests found
...@@ -11,6 +11,7 @@ The following script calculates the PMT time offsets using K40 coincidences ...@@ -11,6 +11,7 @@ The following script calculates the PMT time offsets using K40 coincidences
""" """
# Author: Jonas Reubelt <jreubelt@km3net.de> and Tamas Gal <tgal@km3net.de> # Author: Jonas Reubelt <jreubelt@km3net.de> and Tamas Gal <tgal@km3net.de>
# License: MIT # License: MIT
import os
import km3pipe as kp import km3pipe as kp
import km3pipe.style import km3pipe.style
from km3modules import k40 from km3modules import k40
...@@ -19,29 +20,46 @@ from km3modules.plot import IntraDOMCalibrationPlotter ...@@ -19,29 +20,46 @@ from km3modules.plot import IntraDOMCalibrationPlotter
km3pipe.style.use('km3pipe') km3pipe.style.use('km3pipe')
DET_ID = 39
def main():
pipe = kp.Pipeline(timeit=True) from docopt import docopt
pipe.attach( args = docopt(__doc__)
kp.io.ch.CHPump,
host='127.0.0.1', det_id = int(args['-d'])
port=6001, plots_path = args['-o']
tags='IO_TSL1, IO_MONIT', ligier_ip = args['-l']
timeout=7 * 60 * 60 * 24, ligier_port = int(args['-p'])
max_queue=200000)
pipe.attach(kp.io.ch.CHTagger) det_oid = kp.db.DBManager().get_det_oid(det_id)
pipe.attach(StatusBar, every=50000)
pipe.attach(MemoryObserver, every=100000) pipe = kp.Pipeline(timeit=True)
pipe.attach(k40.MedianPMTRatesService, only_if='IO_MONIT') pipe.attach(
pipe.attach(kp.io.daq.TimesliceParser) kp.io.ch.CHPump,
pipe.attach(k40.TwofoldCounter, tmax=10, dump_filename='../twofold_counts.p') host=ligier_ip,
pipe.attach(Siphon, volume=10 * 60 * 180, flush=True) port=ligier_port,
pipe.attach(k40.K40BackgroundSubtractor) tags='IO_TSL1, IO_MONIT',
pipe.attach(k40.IntraDOMCalibrator, ctmin=-1, det_id=DET_ID) timeout=7 * 60 * 60 * 24,
pipe.attach( max_queue=200000)
IntraDOMCalibrationPlotter, pipe.attach(kp.io.ch.CHTagger)
det_oid="D0DU004MA", pipe.attach(StatusBar, every=50000)
data_path='../data', pipe.attach(MemoryObserver, every=100000)
plots_path='../plots') pipe.attach(k40.MedianPMTRatesService, only_if='IO_MONIT')
pipe.attach(k40.ResetTwofoldCounts) pipe.attach(kp.io.daq.TimesliceParser)
pipe.drain() pipe.attach(
k40.TwofoldCounter,
tmax=10,
dump_filename=os.path.join(plots_path, 'twofold_counts.p'))
pipe.attach(Siphon, volume=10 * 60 * 180, flush=True)
pipe.attach(k40.K40BackgroundSubtractor)
pipe.attach(k40.IntraDOMCalibrator, ctmin=-1, det_id=det_id)
pipe.attach(
IntraDOMCalibrationPlotter,
det_oid=det_oid,
data_path=plots_path,
plots_path=plots_path)
pipe.attach(k40.ResetTwofoldCounts)
pipe.drain()
if __name__ == '__main__':
main()
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment