tfx.orchestration.portable.python_executor_operator.PythonExecutorOperator

PythonExecutorOperator handles python class based executor's init and execution.

Inherits From: BaseExecutorOperator

tfx.orchestration.portable.python_executor_operator.PythonExecutorOperator(
    executor_spec: message.Message,
    platform_spec: Optional[message.Message] = None
)

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

Methods

run_executor

View source

run_executor(
    execution_info: tfx.orchestration.portable.base_executor_operator.ExecutionInfo
) -> execution_result_pb2.ExecutorOutput

Invokers executors given input from the Launcher.

Args
execution_info	A wrapper of the details of this execution.

Returns
The output from executor.

Class Variables
SUPPORTED_EXECUTOR_SPEC_TYPE
SUPPORTED_PLATFORM_SPEC_TYPE