idds/tests/test_core_debug.py

0001 import sys    # noqa F401
0002
0003 from idds.common.constants import ContentStatus
0004 from idds.common.utils import json_loads
0005 from idds.orm.contents import update_contents_ext, update_contents    # noqa F401
0006
0007
0008 params = [{'content_id': 188308635, 'status': ContentStatus.Available},
0009           {'content_id': 188308636, 'status': ContentStatus.Available},
0010           {'content_id': 188308637, 'status': ContentStatus.Available},
0011           {'content_id': 188308638, 'status': ContentStatus.Available},
0012           {'content_id': 188308639, 'status': ContentStatus.Available}]
0013 params = [{'content_id': 188741016, 'status': ContentStatus.Available},
0014           {'content_id': 188741017, 'status': ContentStatus.Available},
0015           {'content_id': 188741018, 'status': ContentStatus.Available},
0016           {'content_id': 188741019, 'status': ContentStatus.Available},
0017           {'content_id': 188741020, 'status': ContentStatus.Available},
0018           {'content_id': 188741021, 'status': ContentStatus.Available},
0019           {'content_id': 188741022, 'status': ContentStatus.Available},
0020           {'content_id': 188741023, 'status': ContentStatus.Available},
0021           {'content_id': 188741024, 'status': ContentStatus.Available},
0022           {'content_id': 188741025, 'status': ContentStatus.Available},
0023           {'content_id': 188741026, 'status': ContentStatus.Available},
0024           {'content_id': 188741027, 'status': ContentStatus.Available}]
0025 # update_contents(params)
0026
0027 # sys.exit(0)
0028
0029 file = '/afs/cern.ch/user/w/wguan/workdisk/iDDS/test/test.log'
0030 f = open(file, "r")
0031 c = f.read()
0032 j = json_loads(c)
0033 contents_ext = j['update_contents_ext']
0034
0035 new_list = []
0036
0037 for col in contents_ext:
0038     new_l = {}
0039     for k in col:
0040         if col[k] is not None:
0041             new_l[k] = col[k]
0042         # new_l['job_status'] = 10
0043     new_list.append(new_l)
0044     # break
0045
0046 print("new_list")
0047 # print(new_list)
0048 print("new_list len: %s" % len(new_list))
0049 update_contents_ext(new_list)
0050 # update_contents_ext(contents_ext)