scr-oath commented on issue #33088:
URL: https://github.com/apache/airflow/issues/33088#issuecomment-1666116748
Just thinking out loud, but if `TaskInstance` could have a copy of the
schedule from its dag and a field (say `outlet_task_id` added to the Dataset
class and populated when a task is triggered by a dataset, that might also be a
good place to put it…
```python
class Dataset:
"""A Dataset is used for marking data dependencies between workflows."""
uri: str = attr.field(validator=[attr.validators.min_len(1),
attr.validators.max_len(3000)])
extra: dict[str, Any] | None = None
outlet_task_id: Optional[str] = None
version: ClassVar[int] = 1
```
--
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]
