Here is the error I am currently getting. The pipeline does not appear to be empty which you can from the debug output I have shared at the end of this post.
"ERROR: : no workflow assigned currently, please check your script" occurs.
hal9000@js-17-8:~/Documents/feature_entk-0.7/bw_sync_01/bw_p14b02_left_d3_k12_1000_k34_1000_1ns_sims_02$ python runme.py --Kconfig gmxcoco.wcfg --RPconfig bluewaters.rcfg
Please assign workflow before invoking run method - cannot proceed
2018-10-25 20:27:49,830: radical.entk.appmanager: MainProcess : MainThread : ERROR : No workflow assigned currently, please check your script
2018-10-25 20:27:49,830: radical.entk.appmanager: MainProcess : MainThread : ERROR : Error in AppManager
Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/radical/entk/appman/appmanager.py", line 208, in run
raise MissingError(obj=self._uid, missing_attribute='workflow')
MissingError: Attribute workflow in radical.entk.appmanager.0000 undefined
Current run failed with error: Error: Attribute workflow in radical.entk.appmanager.0000 undefined
Traceback (most recent call last):
File "runme.py", line 634, in <module>
appman.run()
File "/usr/local/lib/python2.7/dist-packages/radical/entk/appman/appmanager.py", line 468, in run
raise Error(text=ex)
radical.entk.exceptions.Error: Error: Attribute workflow in radical.entk.appmanager.0000 undefined
Here is the debug output with printed object lengths and such.
hal9000@js-17-8:~/Documents/feature_entk-0.7/bw_sync_01/bw_p14b02_left_d3_k12_1000_k34_1000_1ns_sims_02$ python runme.py --Kconfig gmxcoco.wcfg --RPconfig bluewaters.rcfg
iter_cnt = 0
s5.name grompp-stage-0
s6.name = mdrun-stage-0
s7.name = traj-stage-0
s8.name = trajconv-stage-0
s9.name = coco-iter-0
p.name = extasy-pipeline-0
p.__dict__ = {'_stages': [<radical.entk.stage.stage.Stage object at 0x7f24965de350>, <radical.entk.stage.stage.Stage object at 0x7f24965de3d0>, <radical.entk.stage.stage.Stage object at 0x7f24965dee50>, <radical.entk.stage.stage.Stage object at 0x7f24965eb910>, <radical.entk.stage.stage.Stage object at 0x7f2496575250>], '_completed_flag': <threading._Event object at 0x7f24965de290>, '_lock': <thread.lock object at 0x7f2499062610>, '_state': 'DESCRIBED', '_name': 'extasy-pipeline-0', '_uid': 'radical.entk.pipeline.0000', '_state_history': ['DESCRIBED'], '_stage_count': 5, '_cur_stage': 1}
len(p.__dict__) = 9
extasy_pipeline = generate_pipeline(1,Kconfig.num_iterations,Kconfig.num_CUs) Call has been made!
extasy_pipeline.__dict__
{'_stages': [<radical.entk.stage.stage.Stage object at 0x7f24965de350>, <radical.entk.stage.stage.Stage object at 0x7f24965de3d0>, <radical.entk.stage.stage.Stage object at 0x7f24965dee50>, <radical.entk.stage.stage.Stage object at 0x7f24965eb910>, <radical.entk.stage.stage.Stage object at 0x7f2496575250>], '_completed_flag': <threading._Event object at 0x7f24965de290>, '_lock': <thread.lock object at 0x7f2499062610>, '_state': 'DESCRIBED', '_name': 'extasy-pipeline-0', '_uid': 'radical.entk.pipeline.0000', '_state_history': ['DESCRIBED'], '_stage_count': 5, '_cur_stage': 1}
num extasy_pipeline stages = len(ext_pip.stages) = 5
print extasy_pipeline.stages = [<radical.entk.stage.stage.Stage object at 0x7f24965de350>, <radical.entk.stage.stage.Stage object at 0x7f24965de3d0>, <radical.entk.stage.stage.Stage object at 0x7f24965dee50>, <radical.entk.stage.stage.Stage object at 0x7f24965eb910>, <radical.entk.stage.stage.Stage object at 0x7f2496575250>]
extasy_pipeline dict is = {'_stages': [<radical.entk.stage.stage.Stage object at 0x7f24965de350>, <radical.entk.stage.stage.Stage object at 0x7f24965de3d0>, <radical.entk.stage.stage.Stage object at 0x7f24965dee50>, <radical.entk.stage.stage.Stage object at 0x7f24965eb910>, <radical.entk.stage.stage.Stage object at 0x7f2496575250>], '_completed_flag': <threading._Event object at 0x7f24965de290>, '_lock': <thread.lock object at 0x7f2499062610>, '_state': 'DESCRIBED', '_name': 'extasy-pipeline-0', '_uid': 'radical.entk.pipeline.0000', '_state_history': ['DESCRIBED'], '_stage_count': 5, '_cur_stage': 1}
appman.__dict__ before appman.workflow = set([wf])
{'_resource_autoterminate': True, '_completed_queue': [], '_uid': 'radical.entk.appmanager.0000', '_port': 5672, 'shared_data': ['./inp_files/bpti.gro', './inp_files/run1.mdp', './inp_files/run2.mdp', './inp_files/run3.mdp', './inp_files/posre_ca_1000.itp', './inp_files/posre_ca_1000.itp', './inp_files/topol.top', './inp_files/bpti.gro'], '_task_manager': None, '_resubmit_failed': False, '_num_push_threads': 1, '_logger': <logging.Logger object at 0x7f24965de090>, '_mq_hostname': 'localhost', '_mqs_setup': False, '_num_sync_threads': 1, 'resource_desc': {'queue': 'high', 'resource': 'ncsa.bw_aprun', 'cpus': 160, 'project': 'bamm', 'access_schema': 'gsissh', 'walltime': 30}, '_workflow': None, '_cur_attempt': 1, '_num_completed_qs': 1, '_num_pending_qs': 1, '_name': '', '_prof': <radical.utils.profile.Profiler object at 0x7f24965de110>, '_resource_manager': None, '_reattempts': 3, '_pending_queue': [], '_num_pull_threads': 1}
appman.__dict__ after appman.workflow = set([extasy_pipeline])
{'_resource_autoterminate': True, '_completed_queue': [], '_uid': 'radical.entk.appmanager.0000', '_port': 5672, 'shared_data': ['./inp_files/bpti.gro', './inp_files/run1.mdp', './inp_files/run2.mdp', './inp_files/run3.mdp', './inp_files/posre_ca_1000.itp', './inp_files/posre_ca_1000.itp', './inp_files/topol.top', './inp_files/bpti.gro'], '_task_manager': None, '_resubmit_failed': False, '_num_push_threads': 1, 'workflow': set([<radical.entk.pipeline.pipeline.Pipeline object at 0x7f249662cbd0>]), '_logger': <logging.Logger object at 0x7f24965de090>, '_mq_hostname': 'localhost', '_mqs_setup': False, '_num_sync_threads': 1, 'resource_desc': {'queue': 'high', 'resource': 'ncsa.bw_aprun', 'cpus': 160, 'project': 'bamm', 'access_schema': 'gsissh', 'walltime': 30}, '_workflow': None, '_cur_attempt': 1, '_num_completed_qs': 1, '_num_pending_qs': 1, '_name': '', '_prof': <radical.utils.profile.Profiler object at 0x7f24965de110>, '_resource_manager': None, '_reattempts': 3, '_pending_queue': [], '_num_pull_threads': 1}
Please assign workflow before invoking run method - cannot proceed
2018-10-25 22:36:50,950: radical.entk.appmanager: MainProcess : MainThread : ERROR : No workflow assigned currently, please check your script
2018-10-25 22:36:50,950: radical.entk.appmanager: MainProcess : MainThread : ERROR : Error in AppManager
Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/radical/entk/appman/appmanager.py", line 208, in run
raise MissingError(obj=self._uid, missing_attribute='workflow')
MissingError: Attribute workflow in radical.entk.appmanager.0000 undefined
Current run failed with error: Error: Attribute workflow in radical.entk.appmanager.0000 undefined
Traceback (most recent call last):
File "runme.py", line 701, in <module>
appman.run()
File "/usr/local/lib/python2.7/dist-packages/radical/entk/appman/appmanager.py", line 468, in run
raise Error(text=ex)
radical.entk.exceptions.Error: Error: Attribute workflow in radical.entk.appmanager.0000 undefined
Here is the error I am currently getting. The pipeline does not appear to be empty which you can from the debug output I have shared at the end of this post.
"ERROR: : no workflow assigned currently, please check your script" occurs.
Here is the debug output with printed object lengths and such.