TF 2.0 is out! Get hands-on practice at TF World, Oct 28-31. Use code TF20 for 20% off select passes. Register now

tfx.components.base.base_executor.BaseExecutor

View source on GitHub

Class BaseExecutor

Abstract TFX executor class.

__init__

View source

__init__(context=None)

Constructs a beam based executor.

Child Classes

class Context

Methods

Do

View source

Do(
    input_dict,
    output_dict,
    exec_properties
)

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:

None.