Vinci Xu

No, but you can define a for-each action and using it as task's action.

Hi, is the issue have any updates? Now my API also need to upload file, and I documented my struct as below: ```go // swagger:parameters putObject type PutInput struct {...

@n0trace hi, I get a error when mock the interface which embedded a another package's pointer and generic types (`mockgen` is build from your branch): `Loading input failed: unable to...

> dag ins的状态已经被置为 running 额，那这个issue还需要跟进吗

好的，我在本地复现看看，理论上task状态流转为 continue时，下一步就是running了

Hi echo, thanks for your proposal, basically I agree with it. I want declare two points: 1. Worker key limited 0~255 is incorrect, sonyflake is support to use `uint16(0~65536)` as...

在最初的内部场景中是需要cron这个字段，但是因为我们内部存在一个遗留服务，可以用于按照cron的方式去自动调度任务，因此直接把遗留服务改造成了对DAGInstance的创建，所以没在fastflow中支持cron功能。 现在想来除了 @philhuan 提到的问题外，我这里补充一些想法： 1. 执行cron的模块一定是一个独立的模块，并且运行在`master`的节点，因为它的职责是相对独立且复杂的，不要耦合到现存模块，可以叫做`TimerTrigger` 2. 对Cron的实现不推荐创建多个线程，大批量Dag情况会有性能缺陷，建议使用时间轮 3. 对于@phihuan 提到的重启问题，这里分几个角度来看 - `TimerTrigger` 所处的 Master 节点尽量不要出现空置的情况（即master退出后，下一任master当选的这个空档期），否则这个时间段的cron一定会 miss，将master模块和woker模块分开部署可以缓解这个情况。 - 对于miss的cron，可以在dag上记录下上次cron触发的时间，这样就可以master组件起来自动补发由于重启而导致的miss

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

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

不好意思，这部分开箱即用的Action涉及公司内部引用所以尚未改造开源，如果有需求这周末我可以新写个开源版本的pr进来。