In a multi-bundle DAG processor setup, callback fetching is experiencing starvation across different…
In a multi-bundle DAG processor setup, callback fetching is experiencing starvation across different…: a task in LegoFlow-SWE (Harbor dataset). For example, with max callbacks per loop = 2 and three pending dag-processor callbacks distributed across three different bundles ( other-bundle-a …
The task
For example, with `max_callbacks_per_loop = 2` and three pending dag-processor callbacks distributed across three different bundles (`other-bundle-a`, `other-bundle-b`, `testing`), when a manager configured to handle only the `testing` bundle calls `_fetch_callbacks()`, it may receive callbacks from `other-bundle-a`…
Part of Lego-X/LegoFlow-SWE.