tfx.dsl.components.base.base_executor.BaseExecutor

Abstract TFX executor class.

tfx.dsl.components.base.base_executor.BaseExecutor(
    context: Optional[tfx.dsl.components.base.base_executor.BaseExecutor.Context] = None
)

Child Classes

class Context

Methods

`Do`

View source

@abc.abstractmethod
Do(
    input_dict: Dict[Text, List[types.Artifact]],
    output_dict: Dict[Text, List[types.Artifact]],
    exec_properties: Dict[Text, Any]
) -> Optional[execution_result_pb2.ExecutorOutput]

Execute underlying component implementation.

Args
`input_dict`	Input dict from input key to a list of Artifacts. These are often outputs of another component in the pipeline and passed to the component by the orchestration system.
`output_dict`	Output dict from output key to a list of Artifacts. These are often consumed by a dependent component.
`exec_properties`	A dict of execution properties. These are inputs to pipeline with primitive types (int, string, float) and fully materialized when a pipeline is constructed. No dependency to other component or later injection from orchestration systems is necessary or possible on these values.

Returns
execution_result_pb2.ExecutorOutput or None.