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:

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

• I agree to follow this project's Code of Conduct