Skip to content

Display asset watchers in Dag graph #48017

Open
@vincbeck

Description

@vincbeck

Description

With AIP-82 being completed, an asset can have one or multiple asset watchers associated to it. Example:

trigger = MessageQueueTrigger(queue="https://sqs.us-east-1.amazonaws.com/0123456789/Test")
asset = Asset("sqs_asset", watchers=[
    AssetWatcher(name="sqs_asset_watcher", trigger=trigger)
])

with DAG(
    dag_id="example_msgq_watcher",
    schedule=[asset],
    catchup=False,
):
    task = EmptyOperator(task_id="task")

    chain(task)

Today in Airflow we can see the assets in graph view but not the asset watchers:

Image

Use case/motivation

It would be nice to display the different asset watcher(s) associated to assets. That would be valuable information for the user in order to see if the Dag is scheduled based on events.

Related issues

No response

Are you willing to submit a PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

Labels

AIP-82External event driven scheduling in Airflowaffected_version:3.0Issues Reported for 3.0area:UIRelated to UI/UX. For Frontend Developers.area:data-aware-schedulingassets, datasets, AIP-48kind:featureFeature Requests

Type

No type

Projects

No projects

Relationships

None yet

Development

No branches or pull requests

Issue actions