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,
    execution_mode: "pipeline_pb2.Pipeline.ExecutionMode" = pipeline_pb2.Pipeline.SYNC
)

Methods

`generate_output_artifacts`

View source

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

Generates output artifacts given execution_id.

`get_driver_output_uri`

View source

get_driver_output_uri() -> Text

`get_executor_output_uri`

View source

get_executor_output_uri(
    execution_id: int
) -> Text

Generates executor output uri given execution_id.

`get_stateful_working_directory`

View source

get_stateful_working_directory(
    execution_id: Optional[int] = None
) -> Text

Generates stateful working directory given (optional) execution id.

Args
`execution_id`	An optional execution id which will be used as part of the stateful working dir path if provided. The stateful working dir path will be /.system/stateful_working_dir/. If execution_id is not provided, for backward compatibility purposes, is used instead of but an error is raised if the execution_mode is not SYNC (since ASYNC pipelines have no pipeline_run_id).

Returns
Path to stateful working directory.

Raises
`ValueError`	If execution_id is not provided and execution_mode of the pipeline is not SYNC.

`make_tmp_dir`

View source

make_tmp_dir(
    execution_id: int
) -> Text

Generates a temporary directory.