result = await distributor_pipeline_update(params_kw) return result