Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

DAG实例启动后，如何block DAG实例从而阻塞未执行的task #49

Open
lxn3642 opened this issue Dec 19, 2023 · 3 comments
Open

DAG实例启动后，如何block DAG实例从而阻塞未执行的task #49

lxn3642 opened this issue Dec 19, 2023 · 3 comments

Comments

@lxn3642
Copy link

lxn3642 commented Dec 19, 2023 •
edited
Loading

image
有这样一种场景，DAG实例运行过程中发现不符合预期或线上有case需要暂停流程、封禁动作的执行，目前来看貌似不支持此类命令，希望有能够同时阻塞所有dag 实例的运行的命令和阻塞单个实例运行的命令，通过continue或者放开全局锁来解除封禁操作~
辛苦看下当前是否有能够支持该场景的函数/建议如何自行实现~
@ShiningRush
Copy link
Owner

可能的方法是在Dag上实现一些全局命令，命令下发到Dag而不是DagInstance

@NeverTeaser
Copy link

我也有类似的需求，不是很理解上面的回答。我理解目前工作流的执行都是依赖 DagInstance ，在DAG 上实现全局命令，如何能控制DagInstance 或者是正在运行的实例呢，求问~

@ShiningRush
Copy link
Owner

命令下发到Dag维度后就可以在实例运行前检测下Dag本身状态是否允许执行，如果不允许就直接停止掉该工作流所有正在运行的实例

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
3 participants
@ShiningRush @NeverTeaser @lxn3642