tfx.dsl.experimental.latest_artifacts_resolver.LatestArtifactsResolver

Resolver that return the latest n artifacts in a given channel.

Inherits From: BaseResolver

Note that this Resolver is experimental and is subject to change in terms of both interface and implementation.

Methods

resolve

View source

Resolves artifacts from channels by querying MLMD. (deprecated)

Args
pipeline_info PipelineInfo of the current pipeline. We do not want to query artifacts across pipeline boundary.
metadata_handler a read-only handler to query MLMD.
source_channels a key -> channel dict which contains the info of the source channels.

Returns
a ResolveResult instance.

Raises
DeprecationWarning when it is called.

resolve_artifacts

View source

Resolves artifacts from channels by querying MLMD.

Args
metadata_handler A metadata handler to access MLMD store.
input_dict The input_dict to resolve from.

Returns
If min_count for every input is met, returns a Dict[Text, List[Artifact]]. Otherwise, return None.