File indexing completed on 2026-04-10 08:39:00
0001 import sys
0002
0003 try:
0004 testTaskType = sys.argv[1]
0005 except Exception:
0006 testTaskType = "test"
0007
0008 try:
0009 vo = sys.argv[2]
0010 except Exception:
0011 vo = "atlas"
0012
0013 import multiprocessing
0014
0015 from pandajedi.jedicore.JediTaskBufferInterface import JediTaskBufferInterface
0016 from pandajedi.jediddm.DDMInterface import DDMInterface
0017 from pandajedi.jediorder import TaskRefiner
0018
0019 tbIF = JediTaskBufferInterface()
0020 tbIF.setupInterface()
0021
0022
0023 ddmIF = DDMInterface()
0024 ddmIF.setupInterface()
0025
0026
0027 parent_conn, child_conn = multiprocessing.Pipe()
0028
0029 taskRefiner = multiprocessing.Process(target=TaskRefiner.launcher, args=(child_conn, tbIF, ddmIF, vo, testTaskType))
0030 taskRefiner.start()
