tfx.orchestration.portable.outputs_utils.OutputsResolver

This class has methods to handle launcher output related logic.

tfx.orchestration.portable.outputs_utils.OutputsResolver(
    pipeline_node: pipeline_pb2.PipelineNode,
    pipeline_info: pipeline_pb2.PipelineInfo,
    pipeline_runtime_spec: pipeline_pb2.PipelineRuntimeSpec
)

Methods

generate_output_artifacts

View source

generate_output_artifacts(
    execution_id: int
) -> Dict[Text, List[tfx.types.Artifact]]

Generates output artifacts given execution_id.

get_driver_output_uri

View source

get_driver_output_uri()

get_executor_output_uri

View source

get_executor_output_uri(
    execution_id: int
)

Generates executor output uri given execution_id.

get_stateful_working_directory

View source

get_stateful_working_directory()

Generates stateful working directory given execution id.

make_tmp_dir

View source

make_tmp_dir(
    execution_id: int
)

Generates a temporily directory.