Input params are not passed correctly to ewoks
I think it is because of v2 of the ewoks API but not sure. Anyway I got this error:
The above exception was the direct cause of the following exception:
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
ewokscore.task.TaskInputError: Missing inputs for <class 'bes.tasks.MXPipelineInput.MXPipelineInput'>: {'raw_data_path', 'callback'}
The current code, that I think it worked with the first version the params are passed in this format:
{
anomalous: true,
mx_pipeline_name: [ 'EDNA_proc' ],
datasets: [
{
id: 125068083,
name: 'iPfPRS-CD038256_H12-2_2',
startDate: '2023-09-01T14:20:58.196+02:00',
endDate: '2023-09-01T14:20:58.196+02:00',
location: '/tmp/ingestion/MX2405/RAW_DATA/iPfPRS/iPfPRS-CD038256_H12-2_2/DATACOLLECTION-iPfPRS-CD038256_H12-2_2-3023144',
investigation: [Object],
type: 'acquisition',
sampleName: 'CD038256_H12-2_2',
sampleId: 125067896,
parameters: [Array],
instrumentName: 'ID23-1',
meta: [Object]
}
],
callback: 'https://icatplus.esrf.fr/ewoks/91d97aa2-d18a-4d53-ac2c-a13a2d02e138/jobs?id=6520e9e686929e517ffea288',
raw_data_path: [
'/tmp/ingestion/MX2405/RAW_DATA/iPfPRS/iPfPRS-CD038256_H12-2_2/DATACOLLECTION-iPfPRS-CD038256_H12-2_2-3023144'
]
}
What it is expected, however, is a [{name: ... value:...}]
If the above is true @svensson might need to change something on his side?. Ping @denolf
Edited by Alejandro De Maria Antolinos