cadence-workflow - 中断长期运行的 Uber Cadence 活动的正确方法是什么？

Question

如果我有一个长期运行的活动，它会做类似的事情

func Activity(ctx context.Context) error {
    ticker := time.NewTicker(5 * time.Second)
    for {
        select {
        case <-ctx.Done():
            return ctx.Err()
        case <-ticker.C:
            if isServiceReady(ctx) {
                break
            }
        }
    }
    return nil
}

我希望能够从工作流程中取消它（而不取消整个工作流程），然后我将如何做到这一点？

我曾希望您可以在上下文完成通道上接收，然后在工作流中创建一个可取消的上下文，但这显然没有任何作用。

Answer 1

目前要取消活动必须心跳。Cadence 服务在活动心跳返回值上搭载取消状态。因此，如果您在每次滴答时都开始心跳，并且心跳间隔足够小（因为客户端不会在每次心跳方法调用时调用服务），那么您的代码应该开始工作。

将来，我们计划添加带有特定于工作人员的任务列表的会话概念，以提供取消。添加后，取消将不依赖于发送的心跳。