ExecutionDecision records how executor should perform next execution.
tfx.orchestration.data_types.ExecutionDecision(
input_dict: Dict[Text, List[types.Artifact]],
output_dict: Dict[Text, List[types.Artifact]],
exec_properties: Dict[Text, Any],
execution_id: int = None,
use_cached_results: Optional[bool] = False
)
Attributes |
input_dict
|
Updated key -> types.Artifact for inputs that will be used by
actual execution.
|
output_dict
|
Updated key -> types.Artifact for outputs that will be used by
actual execution.
|
exec_properties
|
Updated dict of other execution properties that will be
used by actual execution.
|
execution_id
|
Registered execution_id for the upcoming execution.
|
use_cached_results
|
Whether or not to use a cached result.
|