tfx.dsl.experimental.latest_artifacts_resolver.LatestArtifactsResolver

View source on GitHub

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

Inherits From: BaseResolver

tfx.dsl.experimental.latest_artifacts_resolver.LatestArtifactsResolver(
    desired_num_of_artifacts=1
)

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

Methods

resolve

View source

resolve(
    pipeline_info, metadata_handler, source_channels
)

Resolves artifacts from channels by querying MLMD.

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.