Resolves input artifacts of a pipeline node.
tfx.orchestration.portable.inputs_utils.resolve_input_artifacts(
metadata_handler: tfx.orchestration.metadata.Metadata
,
node_inputs: pipeline_pb2.NodeInputs
) -> Optional[Dict[str, List[types.Artifact]]]
Args |
metadata_handler
|
A metadata handler to access MLMD store.
|
node_inputs
|
A pipeline_pb2.NodeInputs message that instructs artifact
resolution for a pipeline node.
|
Returns |
If min_count for every input is met, returns a Dict[str, List[Artifact]].
Otherwise, return None.
|