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