(wf_ex_id)
| 1332 | wait_jitter_max=cfg.CONF.workflow_engine.retry_max_jitter_msec, |
| 1333 | ) |
| 1334 | def update_workflow_execution(wf_ex_id): |
| 1335 | conductor, wf_ex_db = refresh_conductor(wf_ex_id) |
| 1336 | |
| 1337 | # There is nothing to update if workflow execution is not completed or paused. |
| 1338 | if conductor.get_workflow_status() in statuses.COMPLETED_STATUSES + [ |
| 1339 | statuses.PAUSED |
| 1340 | ]: |
| 1341 | # Update workflow execution and related liveaction and action execution. |
| 1342 | update_execution_records(wf_ex_db, conductor) |
| 1343 | |
| 1344 | |
| 1345 | @retrying.retry( |
no test coverage detected