AardJan opened a new issue, #55133:
URL: https://github.com/apache/airflow/issues/55133

   ### Description
   
   Right now in DagRun → Task → Asset Events, we only see:
   - how many assets a task generated,
   - first 50 of them.
   
   <img width="1542" height="742" alt="Image" 
src="https://github.com/user-attachments/assets/2edb17ea-5475-4872-9083-4798f029ca9a";
 />
   
   That’s pretty limiting. Our users often create tasks with an unknown number 
of datasets (using datasetalias) — sometimes it’s just 1 asset, sometimes a few 
thousand. 
   
   example code:
   ``` python
   import os
   from datetime import datetime
   
   from airflow.sdk import DAG, Asset, AssetAlias, get_current_context, Param
   from airflow.decorators import task
   from airflow.providers.standard.operators.empty import EmptyOperator
   
   DAG_ID = os.path.splitext(os.path.basename(__file__))[0]
   
   asset_alias = AssetAlias("test-airflow-3-dataset-alias")
   
   with DAG(
       dag_id=DAG_ID,
       start_date=datetime(2024, 1, 1),
       schedule=None,
       catchup=False,
       params={
           "dataset_qty": Param(1, type="integer", minimum=1),
       }
   ) as dag:
       start = EmptyOperator(task_id="start")
   
       @task
       def build_dataset_list():
           ctx = get_current_context()
           qty = int(ctx["params"].get("dataset_qty", 1))
           return [f"example_dataset_{i}" for i in range(1, qty + 1)]
   
       @task(outlets=[asset_alias])
       def emit(datasets: list[str], outlet_events):
           for name in datasets:
               print(f"Emitting logical asset event for: {name} via alias 
{asset_alias.name}")
               outlet_events[asset_alias].add(Asset(name))
           return datasets
   
       end = EmptyOperator(task_id="end")
   
       ds_list = build_dataset_list()
       start >> ds_list >> emit(ds_list) >> end
   ```
   
   ### Use case/motivation
   
   We would like to be able to:
   - browse all generated assets for a given task with pagination
   - search/filter them by name
   
   ### Related issues
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [x] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [x] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to