(data)
| 425 | datapipe2 = dp.iter.Grouper(datapipe1, group_key_fn=group_fn, group_size=2) |
| 426 | |
| 427 | def order_fn(data): |
| 428 | data.sort(key=lambda f: f[0], reverse=True) |
| 429 | return data |
| 430 | |
| 431 | datapipe3 = dp.iter.Mapper(datapipe2, fn=order_fn) # type: ignore[var-annotated] |
| 432 |