bolkedebruin commented on issue #50873:
URL: https://github.com/apache/airflow/issues/50873#issuecomment-2901051545
I made a mistake in the dag:
```
from airflow.sdk import Asset, asset
from airflow.sdk import DAG, dag, task
write_example = Asset("write_example")
#@asset(schedule=None)
@dag(schedule=[write_example])
def my_dag():
@task
def consume_csv(w=write_example) -> int:
print("Bla")
return 10
@task
def consume_xcom(x: int):
print(f"received {x}")
y = consume_csv(write_example)
consume_xcom(y)
my_dag()
```
However it sill doesn't show up. There is however a warning
`Cannot activate asset Asset(name="write_example", uri="write_example",
group="asset"); name is already associated to 'file:///tmp/example.csv'`
But I have no clue how to otherwise reference the asset
--
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]
