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 ContentsFeeder
0018
0019 tbIF = JediTaskBufferInterface()
0020 tbIF.setupInterface()
0021
0022 ddmIF = DDMInterface()
0023 ddmIF.setupInterface()
0024
0025 parent_conn, child_conn = multiprocessing.Pipe()
0026
0027 contentsFeeder = multiprocessing.Process(target=ContentsFeeder.launcher, args=(child_conn, tbIF, ddmIF, vo, testTaskType))
0028 contentsFeeder.start()
