Commit 839edf84 by lichenggang

update cp

parent 0d8ab262
Showing with 1 additions and 1 deletions
......@@ -76,7 +76,7 @@ def get_crawler_process_info():
info_dict = dict()
info_dict['pid'] = pid.strip()
info_dict['task_code'] = info['cmdline']['-r']
info_dict['platform'] = info['cmdline']['-mq'].split("_")[0]
info_dict['platform'] = info['cmdline']['-mq'].split("_")[0] if info['cmdline'].get('-mq', '') else 'data_rank'
info_dict['concurrency'] = int(info['cmdline']['-c'])
info_dict['queue'] = info['cmdline']['-mq'] if '-mq' in info['cmdline'] else ''
unic = ''.join([str(info['create_time']), info_dict['task_code'], str(info_dict['concurrency'])]).encode()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment