Recursively ascends until the root action execution is found Useful for finding an original parent workflow. Pass in any ActionExecutionDB instance, and this function will eventually return the top-most action execution, even if the two are one and the same. :param execution_db: Th
(execution_db)
| 477 | |
| 478 | |
| 479 | def get_root_execution(execution_db): |
| 480 | """Recursively ascends until the root action execution is found |
| 481 | |
| 482 | Useful for finding an original parent workflow. Pass in any ActionExecutionDB instance, |
| 483 | and this function will eventually return the top-most action execution, even if the two |
| 484 | are one and the same. |
| 485 | |
| 486 | :param execution_db: The ActionExecutionDB instance for which to find the root parent. |
| 487 | :rtype: ActionExecutionDB |
| 488 | """ |
| 489 | |
| 490 | parent_execution_db = get_parent_execution(execution_db) |
| 491 | |
| 492 | return ( |
| 493 | get_root_execution(parent_execution_db) if parent_execution_db else execution_db |
| 494 | ) |
| 495 | |
| 496 | |
| 497 | def store_execution_output_data( |
nothing calls this directly
no test coverage detected