![]() |
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
generate_output_artifacts(
execution_id: int
) -> Dict[Text, List[types.Artifact]]
Generates output artifacts given execution_id.
get_driver_output_uri
get_driver_output_uri() -> Text
get_executor_output_uri
get_executor_output_uri(
execution_id: int
) -> Text
Generates executor output uri given execution_id.
get_stateful_working_directory
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 |
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
make_tmp_dir(
execution_id: int
) -> Text
Generates a temporary directory.