Исправление phoen, (текущая версия) :
Очень похоже что тебе нужен airflow: это и шедуллер, и своего рода оркестратор, и оперирует он понятиями DAG (directed acyclic graph) состоящими из тасков (крайне похожими на твой псевдокод).
Единственная проблема которая может возникнуть - назначать задачу на конкретный воркер, но вроде и она решаема через назначение конкретной queue для таска.
Исправление phoen, :
Очень похоже что тебе нужен airflow: это и шедуллер, и своего рода оркестратор, и оперирует он понятиями DAG (directed acyclic graph) состоящими из тасков (крайне похожими на твой псевдокод). Единственная проблема которая может возникнуть - назначать задачу на конкретный воркер, но вроде и она решаема через назначение конкретной queue для таска.
Исправление phoen, :
Очень похоже что тебе нужен airflow: это и шедуллер, и своего рода оркестратор, и оперирует он понятиями DAG (directed acyclic graph) состоящими из тасков (крайне похожими на твой псевдокод). Единственная проблема которая может возникнуть - назначать задачу на конкретный воркер, но вроде и она решаема через назначение конкретной queue.
Исходная версия phoen, :
Очень похоже что тебе нужен airflow: это и шедуллер, и своего рода оркестратор, и оперирует он понятиями DAG (directed acyclic graph) состоящими из тасков (крайне похожими на твой псевдокод). Единственная проблема которая может возникнуть - назначать задачу на конкретный воркер, но вроде и она решаема через назначение конкретной queue.