how to call task flows define in yaml config file from remote server?

[selinon]

how to call task flows define in yaml config file from remote server?

[fridex]

Yes, you are right. I will update the docs.

To run some flow (let's say "myFlow"), just call run_flow function and supply arguments to the flow:

from selinon import run_flow

run_flow('myFlow', node_args={'foo': 'bar'})

If you would like to run only some tasks in a flow, use the run_flow_selective function:

from selinon import run_flow_selective

run_flow_selective('myFlow', ['Task1', 'Task2'], node_args={'foo': 'bar'})

If there is anything unclear, feel free to ask.

[dusteye]

I have another quetion: how to fetch the flow result? I found that run_flow result is a celery asyncResult, but use get method celery asyncResult, it's blocked and can not return.

[fridex]

I have another quetion: how to fetch the flow result? I found that run_flow result is a celery asyncResult, but use get method celery asyncResult, it's blocked and can not return.

The run_flow function returns async result for dispatcher that is handling the requested flow. Results are stored on task level based on assigned adapters. There is no mechanism to get results of all tasks in the flow as they can use different storages and the structure of stored results in storages/adapters is left on users.

You can run a flow with arguments based on which you can query storage/database in the adapter implementation - you can request the given storage adapter from pool and call querying methods to get results. You need to know at least task name (and possibly storage adapter) that results you want to get.

It might sound difficult, but it is not. I can provide you some example if you want.

[fridex]

OK, I will close this. @dusteye feel free to reopen if more input is needed.