idds/tests/panda_client_test.py

0001 import pandaclient.idds_api as idds_api
0002 import idds.common.utils as idds_utils
0003
0004 # setup connection and get jtids
0005 conn = idds_api.get_api(idds_utils.json_dumps, idds_host=None, compress=True, manager=True)
0006 reqid = 5460
0007 ret = conn.get_requests(request_id=int(reqid), with_detail=True)
0008 print(ret)
0009 jtids = [task["transform_workload_id"] for task in ret[1][1] if task["transform_status"]["attributes"]["_name_"] != "Finished"]
0010 print(jtids)
0011
0012 # this first jtid works fine
0013 jtid = jtids[0]
0014 print(jtid)
0015 ret = conn.get_contents_output_ext(request_id=reqid, workload_id=jtid)
0016 print(ret[1][0])
0017 # print(ret[1][1])
0018
0019 # other jtids do not work
0020 jtid = jtids[1]
0021 print(jtid)
0022 ret = conn.get_contents_output_ext(request_id=reqid, workload_id=jtid)
0023 print(ret[1][0])
0024 print(ret[1][1])