dstandish opened a new issue, #57696:
URL: https://github.com/apache/airflow/issues/57696
### Body
I.e. do you need to declare an asset to be partitioned in order to update
partitions of it? I'm not so sure.
E.g. we could have this dag
```python
asset1 = Asset(
name="something_segment_1",
)
with DAG(
dag_id="update_segment",
schedule=None,
tags=["segment"],
):
@task(outlets=[asset1])
def hooray(dag_run: DagRun = None):
time.sleep(1)
print(f"partition_key: {dag_run.partition_key}")
hooray()
```
And it could be updated for a specific partition if the dag _runs_ for a
specific partition.
### Committer
- [x] I acknowledge that I am a maintainer/committer of the Apache Airflow
project.
--
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]
