TJaniF commented on issue #48737:
URL: https://github.com/apache/airflow/issues/48737#issuecomment-2789093577
Sorry for the delay here, it is fixed for assets in regular tasks (the dag
in the issue) but not for dynamically mapped tasks yet.
I tried this dag:
```
from airflow.decorators import dag, task
from airflow.datasets import Dataset
@dag()
def dataset_dtm():
@task
def upstream_task():
return [1,2,3]
@task(
outlets=[Dataset("MY_MAPPED_DATASETB")],
)
def map_me(x):
print(x)
map_me.expand(x=upstream_task())
dataset_dtm()
```
Started up breeze and immediately ran the dag:
Even after waiting 10 minutes the dag still fails... 😅
--
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]
