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 JobGenerator
0007
0008 tbIF = JediTaskBufferInterface()
0009 tbIF.setupInterface()
0010
0011
0012 ddmIF = DDMInterface()
0013 ddmIF.setupInterface()
0014
0015
0016 parent_conn, child_conn = multiprocessing.Pipe()
0017
0018 try:
0019 testVO = sys.argv[1]
0020 except Exception:
0021 testVO = "atlas"
0022
0023 try:
0024 testTaskType = sys.argv[2]
0025 except Exception:
0026 testTaskType = "test"
0027
0028 try:
0029 execJob = False
0030 if sys.argv[3] == "y":
0031 execJob = True
0032 except Exception:
0033 pass
0034
0035 try:
0036 testClouds = sys.argv[4].split(",")
0037 except Exception:
0038 testClouds = [None]
0039
0040 print(f"{testVO} {testTaskType} {testClouds}")
0041
0042 gen = multiprocessing.Process(target=JobGenerator.launcher, args=(child_conn, tbIF, ddmIF, testVO, testTaskType, testClouds, False, execJob, None, True))
0043 gen.start()
