File indexing completed on 2026-04-09 07:58:21
0001
0002 from idds.core.messages import retrieve_messages
0003
0004 """
0005 msgs = retrieve_messages(bulk=1000000)
0006 to_check_msgs = []
0007 for msg in msgs:
0008 # print(msg['msg_id'], msg)
0009 if msg['msg_content']['workload_id'] == 20525133:
0010 to_check_msgs.append(msg)
0011 for to_check_msg in to_check_msgs:
0012 print(to_check_msg)
0013 contents = to_check_msg['msg_content']['files']
0014 print("number of files: %s" % len(contents))
0015 for content in contents:
0016 pass
0017 # print(content)
0018 """
0019 msgs = retrieve_messages(bulk_size=1000000)
0020 for msg in msgs:
0021 if msg['request_id'] == 152:
0022 print(msg)
