考虑将字符串数组作为输入,我的目标是为每个字符串安排 cron 作业。我已经尝试为每次输入迭代创建自定义工作流选项并执行相同的操作。在此之后,只有第一个 cron 工作流被安排,而其他 cron 作业无限期地等待。
for ind , sid := range ss_ids {
var cronScheduleStr string
if ind == 0 {
cronScheduleStr = "* * * * *"
}
if ind == 1 {
cronScheduleStr = "2 * * * *"
}
workflowID := "cron_" + sid
workflowOptions := client.StartWorkflowOptions{
ID: workflowID,
TaskQueue: "cron",
CronSchedule: cronScheduleStr,
}
we, err := c.ExecuteWorkflow(context.Background(), workflowOptions, cron.SampleCronWorkflow,sid)
if err != nil {
log.Fatalln("Unable to execute workflow", err)
}
log.Println("Started workflow", "WorkflowID", we.GetID(), "RunID", we.GetRunID())
}
除此之外,我以相同的方式尝试了子工作流程,但这也只安排了第一个 cron 子工作流程。如果有人可以提供帮助,那就太好了。