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()
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.
|