tfx.orchestration.portable.base_executor_operator.BaseExecutorOperator

View source on GitHub

The base class of all executor operators.

tfx.orchestration.portable.base_executor_operator.BaseExecutorOperator(
    executor_spec: message.Message,
    platform_config: Optional[message.Message] = None
)

Args
executor_spec	The specification of how to initialize the executor.
platform_config	The specification of how to allocate resource for the executor.

Raises
RuntimeError	if the executor_spec or platform_config is not supported.

Methods

SUPPORTED_EXECUTOR_SPEC_TYPE

View source

SUPPORTED_EXECUTOR_SPEC_TYPE()

SUPPORTED_PLATFORM_CONFIG_TYPE

View source

SUPPORTED_PLATFORM_CONFIG_TYPE()

run_executor

View source

@abc.abstractmethod
run_executor(
    execution_info: tfx.orchestration.portable.data_types.ExecutionInfo
) -> execution_result_pb2.ExecutorOutput

Invokes the executor with inputs provided by the Launcher.

Args
execution_info	A wrapper of the info needed by this execution.

Returns
The output from executor.