如何将yaml属性传递给优步Cadence cronSchedule注释

Question

我是uber Cadence的新手，尝试编写一个cron调度任务。Cadence提供了一个cron附表注释（在网上找个例子），它需要一个cron表达式字符串，用于在特定时间触发方法。但是，我想让这个cron表达式按照我们在yml文件中设置的来加载。有什么方法可以做到吗？我目前只找到了这个@cron附表注释的方法来做。我还发现有一个Workflow Option可以设置cron附表。但是，不知道如何使用它来触发方法。下面是当前的代码。

public interface CronTask {


    @WorkflowMethod(
            workflowId = CRON_WORKFLOW_ID,
            taskList = TASK_LIST,
            executionStartToCloseTimeoutSeconds = 30,
            workflowIdReusePolicy = WorkflowIdReusePolicy.TerminateIfRunning
    )
    @CronSchedule("*/1 * * * *") 
    void kickOff(String name);
}

如果没有办法做到这一点。有人知道我们是否可以简单地用spring @Scheduled替换这个< code>@CronSchedule注释吗？批注< code>WorkflowMethod是否仍能按预期工作？

Answer 1

在时态中，您可以通过工作流选项来执行此操作：

    WorkflowOptions workflowOptions =
        WorkflowOptions.newBuilder()
            .setWorkflowId(WORKFLOW_ID)
            .setTaskQueue(TASK_QUEUE)
            .setCronSchedule("* * * * *")
            .setWorkflowExecutionTimeout(Duration.ofMinutes(3))
            .setWorkflowRunTimeout(Duration.ofMinutes(1))
            .build();

    // Create the workflow client stub. It is used to start our workflow execution.
    GreetingWorkflow workflow = client.newWorkflowStub(GreetingWorkflow.class, workflowOptions);

我相信卡登斯也有类似的能力。