smalsale commented on issue #32700: URL: https://github.com/apache/airflow/issues/32700#issuecomment-1648683443
> 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 []
> ```
Here is a conf for the failed run
```
{
"flights": [
{
"flight_id": 4478824448
},
{
"flight_id": 4478824449
},
{
"flight_id": 4478824451
},
{
"flight_id": 4478824456
},
{
"flight_id": 4478824457
},
{
"flight_id": 4478824459
},
{
"flight_id": 4478824460
},
{
"flight_id": 4478685201
},
{
"flight_id": 4478824466
},
{
"flight_id": 4478824468
},
{
"flight_id": 4478824469
},
{
"flight_id": 4478824471
},
{
"flight_id": 4478824481
},
{
"flight_id": 4478683183
},
{
"flight_id": 4478826547
},
{
"flight_id": 4478685246
},
{
"flight_id": 4478824516
},
{
"flight_id": 4478826572
},
{
"flight_id": 4478824528
},
{
"flight_id": 4478826580
},
{
"flight_id": 4478685270
},
{
"flight_id": 4478824540
},
{
"flight_id": 4478824554
},
{
"flight_id": 4478683245
},
{
"flight_id": 4478685294
},
{
"flight_id": 4478824557
},
{
"flight_id": 4478824559
},
{
"flight_id": 4478824562
},
{
"flight_id": 4478826614
},
{
"flight_id": 4478685308
},
{
"flight_id": 4478824574
},
{
"flight_id": 4478599301
},
{
"flight_id": 4478826631
},
{
"flight_id": 4478824585
},
{
"flight_id": 4478683285
},
{
"flight_id": 4478824602
},
{
"flight_id": 4478685341
},
{
"flight_id": 4478824606
},
{
"flight_id": 4478826654
},
{
"flight_id": 4478824609
},
{
"flight_id": 4478685347
},
{
"flight_id": 4478824618
},
{
"flight_id": 4478826667
},
{
"flight_id": 4478685359
},
{
"flight_id": 4478824624
},
{
"flight_id": 4478824625
},
{
"flight_id": 4478685364
},
{
"flight_id": 4478824635
},
{
"flight_id": 4478685376
},
{
"flight_id": 4478824641
},
{
"flight_id": 4478824649
},
{
"flight_id": 4478824655
},
{
"flight_id": 4478824656
},
{
"flight_id": 4478824657
},
{
"flight_id": 4478824658
},
{
"flight_id": 4478685422
},
{
"flight_id": 4478824691
},
{
"flight_id": 4478824692
},
{
"flight_id": 4478685437
},
{
"flight_id": 4478685444
},
{
"flight_id": 4478824709
},
{
"flight_id": 4478683398
},
{
"flight_id": 4478685448
},
{
"flight_id": 4478685457
},
{
"flight_id": 4478824724
},
{
"flight_id": 4478824725
},
{
"flight_id": 4478824728
},
{
"flight_id": 4478685467
},
{
"flight_id": 4478683423
},
{
"flight_id": 4478800160
},
{
"flight_id": 4478824738
},
{
"flight_id": 4478826792
},
{
"flight_id": 4478824750
},
{
"flight_id": 4478824751
},
{
"flight_id": 4478685489
},
{
"flight_id": 4478824766
},
{
"flight_id": 4478824769
},
{
"flight_id": 4478685513
},
{
"flight_id": 4478685515
},
{
"flight_id": 4478685518
},
{
"flight_id": 4478824784
},
{
"flight_id": 4478685529
},
{
"flight_id": 4478824796
},
{
"flight_id": 4478685549
},
{
"flight_id": 4478683507
},
{
"flight_id": 4478683513
},
{
"flight_id": 4478824827
},
{
"flight_id": 4478685564
},
{
"flight_id": 4478824829
},
{
"flight_id": 4478685568
},
{
"flight_id": 4478824840
},
{
"flight_id": 4478824844
},
{
"flight_id": 4478824847
},
{
"flight_id": 4478826906
},
{
"flight_id": 4478824871
},
{
"flight_id": 4478683566
},
{
"flight_id": 4478685615
},
{
"flight_id": 4478720435
},
{
"flight_id": 4478683574
},
{
"flight_id": 4478685622
},
{
"flight_id": 4478685629
},
{
"flight_id": 4478824900
},
{
"flight_id": 4478824901
},
{
"flight_id": 4478423495
},
{
"flight_id": 4478824908
},
{
"flight_id": 4478826966
},
{
"flight_id": 4478423512
},
{
"flight_id": 4478824921
},
{
"flight_id": 4478824922
},
{
"flight_id": 4478685663
},
{
"flight_id": 4478824934
},
{
"flight_id": 4478824941
},
{
"flight_id": 4478685680
},
{
"flight_id": 4478824950
},
{
"flight_id": 4478685697
},
{
"flight_id": 4478824963
},
{
"flight_id": 4478683653
},
{
"flight_id": 4478824970
},
{
"flight_id": 4478683666
},
{
"flight_id": 4478685719
},
{
"flight_id": 4478683672
},
{
"flight_id": 4478685721
},
{
"flight_id": 4478824984
},
{
"flight_id": 4478824985
},
{
"flight_id": 4478685741
},
{
"flight_id": 4478685747
},
{
"flight_id": 4478685749
},
{
"flight_id": 4478825013
},
{
"flight_id": 4478825032
},
{
"flight_id": 4478825038
},
{
"flight_id": 4478685783
},
{
"flight_id": 4478825050
},
{
"flight_id": 4478685790
},
{
"flight_id": 4478825065
},
{
"flight_id": 4478825071
},
{
"flight_id": 4478683770
},
{
"flight_id": 4478825083
},
{
"flight_id": 4478825085
},
{
"flight_id": 4478685825
},
{
"flight_id": 4478825095
},
{
"flight_id": 4478685836
},
{
"flight_id": 4478685855
},
{
"flight_id": 4478825127
},
{
"flight_id": 4478685865
},
{
"flight_id": 4478825130
},
{
"flight_id": 4478685869
},
{
"flight_id": 4478683833
},
{
"flight_id": 4478825145
},
{
"flight_id": 4478825149
},
{
"flight_id": 4478685887
},
{
"flight_id": 4478825152
},
{
"flight_id": 4478825154
},
{
"flight_id": 4478825160
},
{
"flight_id": 4478825163
},
{
"flight_id": 4478825164
},
{
"flight_id": 4478821072
},
{
"flight_id": 4478825170
},
{
"flight_id": 4478556888
},
{
"flight_id": 4478685913
},
{
"flight_id": 4478685914
},
{
"flight_id": 4478825177
},
{
"flight_id": 4478827224
},
{
"flight_id": 4478825184
},
{
"flight_id": 4478765793
},
{
"flight_id": 4478685927
},
{
"flight_id": 4478421747
},
{
"flight_id": 4478685953
},
{
"flight_id": 4478421765
},
{
"flight_id": 4478685959
},
{
"flight_id": 4478825223
},
{
"flight_id": 4478825225
},
{
"flight_id": 4478825249
},
{
"flight_id": 4478685987
},
{
"flight_id": 4478825259
},
{
"flight_id": 4478825267
},
{
"flight_id": 4478825272
},
{
"flight_id": 4478683976
},
{
"flight_id": 4478683978
},
{
"flight_id": 4478825290
},
{
"flight_id": 4478686028
},
{
"flight_id": 4478686029
},
{
"flight_id": 4478686041
},
{
"flight_id": 4478686042
},
{
"flight_id": 4478686043
},
{
"flight_id": 4478686044
},
{
"flight_id": 4478825314
},
{
"flight_id": 4478421863
},
{
"flight_id": 4478686058
},
{
"flight_id": 4478686059
},
{
"flight_id": 4478557036
},
{
"flight_id": 4478825327
},
{
"flight_id": 4478686075
},
{
"flight_id": 4478825342
},
{
"flight_id": 4478686079
},
{
"flight_id": 4478825346
},
{
"flight_id": 4478686087
},
{
"flight_id": 4478825352
},
{
"flight_id": 4478827401
},
{
"flight_id": 4478686096
},
{
"flight_id": 4478686097
},
{
"flight_id": 4478686099
},
{
"flight_id": 4478686104
},
{
"flight_id": 4478686107
},
{
"flight_id": 4478686120
},
{
"flight_id": 4478686124
},
{
"flight_id": 4478825388
},
{
"flight_id": 4478557103
},
{
"flight_id": 4478686132
},
{
"flight_id": 4478686134
},
{
"flight_id": 4478825398
},
{
"flight_id": 4478686137
},
{
"flight_id": 4478825401
},
{
"flight_id": 4478825404
},
{
"flight_id": 4478686152
},
{
"flight_id": 4478686157
},
{
"flight_id": 4478825425
},
{
"flight_id": 4478825434
},
{
"flight_id": 4478684125
},
{
"flight_id": 4478686173
},
{
"flight_id": 4478686182
},
{
"flight_id": 4478557167
},
{
"flight_id": 4478825455
},
{
"flight_id": 4478684146
},
{
"flight_id": 4478684150
},
{
"flight_id": 4478827511
},
{
"flight_id": 4478686200
},
{
"flight_id": 4478686211
},
{
"flight_id": 4478686216
},
{
"flight_id": 4478700554
},
{
"flight_id": 4478700556
},
{
"flight_id": 4478684174
},
{
"flight_id": 4478825486
},
{
"flight_id": 4478686228
},
{
"flight_id": 4478825494
},
{
"flight_id": 4478686235
},
{
"flight_id": 4478686240
},
{
"flight_id": 4478825507
},
{
"flight_id": 4478825512
},
{
"flight_id": 4478557226
},
{
"flight_id": 4478684206
},
{
"flight_id": 4478686254
},
{
"flight_id": 4478686270
},
{
"flight_id": 4478686271
},
{
"flight_id": 4478684226
},
{
"flight_id": 4478647368
},
{
"flight_id": 4478647369
},
{
"flight_id": 4478686281
},
{
"flight_id": 4478825546
},
{
"flight_id": 4478684243
},
{
"flight_id": 4478692438
},
{
"flight_id": 4478686295
},
{
"flight_id": 4478686297
},
{
"flight_id": 4478692441
},
{
"flight_id": 4478686302
},
{
"flight_id": 4478686303
},
{
"flight_id": 4478686315
},
{
"flight_id": 4478825582
},
{
"flight_id": 4478686321
},
{
"flight_id": 4478684285
},
{
"flight_id": 4478686334
},
{
"flight_id": 4478686338
},
{
"flight_id": 4478825614
},
{
"flight_id": 4478825615
},
{
"flight_id": 4478686355
},
{
"flight_id": 4478686356
},
{
"flight_id": 4478686358
},
{
"flight_id": 4478686363
},
{
"flight_id": 4478825629
},
{
"flight_id": 4478686366
},
{
"flight_id": 4478825648
},
{
"flight_id": 4478686388
},
{
"flight_id": 4478825652
},
{
"flight_id": 4478461111
},
{
"flight_id": 4478825668
},
{
"flight_id": 4478825680
},
{
"flight_id": 4478684372
},
{
"flight_id": 4478686424
},
{
"flight_id": 4478686425
},
{
"flight_id": 4478825692
},
{
"flight_id": 4478684386
},
{
"flight_id": 4478684389
},
{
"flight_id": 4478790885
},
{
"flight_id": 4478786800
},
{
"flight_id": 4478825713
},
{
"flight_id": 4478825715
},
{
"flight_id": 4478686456
},
{
"flight_id": 4478686457
},
{
"flight_id": 4478686460
},
{
"flight_id": 4478825727
},
{
"flight_id": 4478825738
},
{
"flight_id": 4478825740
},
{
"flight_id": 4478825748
},
{
"flight_id": 4478827796
},
{
"flight_id": 4478686535
},
{
"flight_id": 4478686638
},
{
"flight_id": 4478825927
},
{
"flight_id": 4478825993
},
{
"flight_id": 4478825995
},
{
"flight_id": 4478824002
},
{
"flight_id": 4478824101
}
]
}
```
--
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]
