idds/tests/message_test1.py

0001
0002 import json
0003
0004 from idds.core.messages import retrieve_messages
0005
0006 msgs = retrieve_messages()
0007 for msg in msgs:
0008     if msg['msg_id'] in [323720]:
0009         # print(msg)
0010         msg_sent = json.dumps(msg['msg_content'])
0011         print(msg_sent)
0012
0013         recover_msg = json.loads(msg_sent)
0014         if recover_msg['relation_type'] == 'output':
0015             # only parse messages from output contents
0016             points = recover_msg['files']
0017             for point in points:
0018                 hp_loss = point['path']
0019                 hp_loss = json.loads(hp_loss)
0020                 hp, loss = hp_loss
0021                 print(hp)
0022                 print(loss)
0023                 model_id, hp_point = hp
0024                 print(model_id)
0025                 print(hp_point)