run_async

PythonScript.run_async(parameter=None)

发送python脚本任务信息并返回Task实例

该方法不会等待任务执行结果，任务信息将被提交至celery任务队列， 待有可用并发数时执行，执行结果可通过Task实例的 get_result 方法得到

参数

parameter (Optional[Any]) – 脚本入参

Returns: python脚本任务id

示例

from deepfos.element.pyscript import PythonScript

script = PythonScript(element_name='test_task',
                      path='/',
                      should_log=True)

script.run_async(parameter={'a': 1})

线上执行时，将执行发送当前空间内元素路径为’/’， 元素名为test_task的python脚本的任务，且由于初始化时should_log为True， 其在作业管理中将更新作业信息

可通过如下代码等待并获得结果，如不使用，任务亦会照常执行，如记录了任务id， 可通过python组件的/script/result/{任务id}接口得到结果

res = script.get_result()

参见

run LocalTask OnlineTask

返回类型

AbstractPythonTask