artifacts.OnArtifact#

class union.artifacts.OnArtifact(trigger_on, inputs=None)#

Event used to link upstream and downstream workflows together.

Parameters:

  • trigger_on (Artifact | ArtifactQuery) – Artifact on which to trigger.

  • inputs (Dict[str, Any | Artifact | ArtifactQuery] | None) – Dict of inputs.

Example usage:

OnArtifact(
    trigger_on=dailyArtifact,
    inputs={
        # Use the matched Artifact
        "today_upstream": dailyArtifact,
        "yesterday_upstream": dailyArtifact.query(
            time_partition=dailyArtifact.
            time_partition - timedelta(days=1)),
        # Use the matched hourly Artifact
        "other_daily_upstream": hourlyArtifact.query(
            partitions={"region": "LAX"}),
        # Static value "SEA" that will be passed as input
        "region": "SEA",
        "other_artifact": UnrelatedArtifact.query(
            time_partition=dailyArtifact.
            time_partition - timedelta(days=1)),
        "other_artifact_2": UnrelatedArtifact.query(
            time_partition=hourlyArtifact.time_partition.truncate_to_day()),
        "other_artifact_3": UnrelatedArtifact.query(
            region=hourlyArtifact.time_partition.truncate_to_day()),
    },
)