result = await distributor_pipeline_create(params_kw)
return result