dimberman commented on PR #34311:
URL: https://github.com/apache/airflow/pull/34311#issuecomment-1904645091
@potiuk @hussein-awala @styannik apologies for being out of the loop here.
Been a bit swamped on my end :).
I think that raising an exception here is the wrong way to go about this.
I think there should be a slightly larger conversation about what we
do/return when we run `dag.test`.
One thought I've been having recently is that we should have dag.test return
a dictionary of tasks -> status.
So let's say we have a task that fails with an exception, maybe we could
have a dictionary read
```python
{
"task_a": { "status": "success"},
"task_b": {"status": "failed", "exc_info": DivideByZeroException(...)},
"dag_status": "failed",
}```
This way people can run tests against their DAGs with different inputs and
see what failure/acceptance scenarios have, and the tests will correctly fail
as you can take the result and run assertions. WDYT?
--
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]
