hussein-awala commented on issue #32700:
URL: https://github.com/apache/airflow/issues/32700#issuecomment-1646635818
Could you provide the dag run conf for the failed dag run?
Also, could you try returning an empty list when the flights is None?
```python
def validate(**kwargs) -> List[Dict]:
payload: dict = {key: value for key, value in
list(kwargs['dag_run'].conf.items())}
# payload is a list of dicts
# [ {"flight_id": 123},
# {"flight_id": 456}
# ]
if not payload or all(isinstance(x, dict) for x in payload):
raise AirflowFailException(f"Bad Config Submitted:
{kwargs['dag_run'].conf}")
return payload["flights"] or []
```
--
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]
