Skip to content

Asset decorated dag with every trigger is making a new dag version #63724

@atul-astronomer

Description

@atul-astronomer

Apache Airflow version

main (development)

If "Other Airflow 3 version" selected, which one?

No response

What happened?

Image

What you think should happen instead?

No response

How to reproduce

Use the below Dag to reproduce the issue on airflow main branch:

from __future__ import annotations

import pendulum

from airflow.sdk import Asset, asset, dag, task


@asset(uri="s3://bucket/asset1_producer", schedule=None)
def asset1_producer():
    pass


@asset(uri="s3://bucket/object", schedule=None)
def asset2_producer(self, context, asset1_producer):
    print(self)
    print(context["inlet_events"][asset1_producer])

Operating System

Linux

Versions of Apache Airflow Providers

No response

Deployment

Other

Deployment details

No response

Anything else?

No response

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

Labels

affected_version:3.2.0betaUse for reporting issues with 3.2.0betaarea:corekind:bugThis is a clearly a bugpriority:highHigh priority bug that should be patched quickly but does not require immediate new release

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions