Skip to content

Resolve "Input params are not passed correctly to ewoks"

Closes #458

The parameters to execute are now passed as:

[
  { name: 'anomalous', value: true },
  { name: 'mx_pipeline_name', value: [ 'EDNA_proc' ] },
  { name: 'datasets', value: [ [Object] ] },
  {
    name: 'callback',
    value: 'https://icatplus.esrf.fr/ewoks/91d97aa2-d18a-4d53-ac2c-a13a2d02e138/jobs?id=6520ec2e16fa21550653982c'
  },
  {
    name: 'raw_data_path',
    value: [
      '/tmp/ingestion/MX2405/RAW_DATA/iPfPRS/iPfPRS-CD038256_H12-2_2/DATACOLLECTION-iPfPRS-CD038256_H12-2_2-3023144'
    ]
  }
]

However, as expected, BES is unhappy:


Traceback (most recent call last):
  File "/opt/pxsoft/mxworkflows/id30a2/miniconda3/envs/id30a2/lib/python3.9/site-packages/ewokscore/events/contexts.py", line 88, in _context
    yield execinfo
  File "/opt/pxsoft/mxworkflows/id30a2/miniconda3/envs/id30a2/lib/python3.9/site-packages/ewokscore/events/contexts.py", line 54, in job_context
    yield execinfo
  File "/opt/pxsoft/mxworkflows/id30a2/miniconda3/envs/id30a2/lib/python3.9/site-packages/ewoks/bindings.py", line 78, in execute_graph
    result = mod.execute_graph(graph, execinfo=execinfo, **execute_options)
  File "/opt/pxsoft/mxworkflows/id30a2/miniconda3/envs/id30a2/lib/python3.9/site-packages/ewokscore/events/contexts.py", line 25, in wrapper
    return method(*args, execinfo=execinfo, **kw)
  File "/mnt/multipath-shares/sware/exp/pxsoft/mxworkflows/id30a2/ewoksppf/src/ewoksppf/bindings.py", line 590, in execute_graph
    return ppfgraph.run(**execute_options)
  File "/mnt/multipath-shares/sware/exp/pxsoft/mxworkflows/id30a2/ewoksppf/src/ewoksppf/bindings.py", line 555, in run
    raise ex
  File "/opt/pxsoft/mxworkflows/id30a2/miniconda3/envs/id30a2/lib/python3.9/site-packages/pypushflow/concurrent/process.py", line 78, in cb
    result = future.result()
  File "/opt/pxsoft/mxworkflows/id30a2/miniconda3/envs/id30a2/lib/python3.9/concurrent/futures/_base.py", line 439, in result
    return self.__get_result()
  File "/opt/pxsoft/mxworkflows/id30a2/miniconda3/envs/id30a2/lib/python3.9/concurrent/futures/_base.py", line 391, in __get_result
    raise self._exception
RuntimeError: Task 'MXPipelineInput' failed

@svensson @denolf help is appreciated here

Edited by Alejandro De Maria Antolinos

Merge request reports