TJaniF commented on issue #48737:
URL: https://github.com/apache/airflow/issues/48737#issuecomment-2781634050
Update, I encountered this issue in another situation:
when using an asset/dataset in a dynamically mapped task the asset never
shows up in the Asset list _until_ you run `airflow dags reserialize`
```
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()
```
The above dag runs and works fine in 2.10. In 3.0 current main it fails with
the same InactiveAsset error int he api server. The `map_me` task fails without
any indication as to why in the logs.
The difference to the situation @vatsrahul1001 and I were investigating last
week is that no matter how long you wait the asset does not show up in the UI
asset list until the manual reserialization command is run.
Since many users cannot run this command easily in their production Airflow
instance nor would know that this is the fix, this constitutes a breaking bug,
imho 👀
--
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]
