如何将workflow.Context传递给Cadence活动

Question

我想把<代码>工作流程。睡眠调用我的Cadence活动之一，以便能够正确测试它（并模拟Sleepfunction产生的错误结果）。

在实现之前，我注意到两件重要的事情：

• 上下文。上下文和工作流。上下文是单独的类型。
• 每个活动的第一个参数 - 上下文。上下文 - 是可选的，可以省略

我的尝试:

1.首次尝试

import "go.uber.org/cadence/workflow"

// Activity:    
func (s *MyActivities) WorkflowSleep(_ context.Context, workflowCtx workflow.Context, duration time.Duration) error {
    return workflow.Sleep(workflowCtx, duration)
}

// In workflow; ctx has type workflow.Context:
    err := workflow.ExecuteActivity(ctx, myActivities.WorkflowSleep, ctx, duration).Get(ctx, nil)

错误：

"error"："无法解码活动函数输入字节错误：无法解码参数：0，*internal.Context，json错误：json：无法将对象散集到Go函数类型的值internal.Context

2.第二次尝试

import "go.uber.org/cadence/workflow"

// Activity:    
func (s *MyActivities) WorkflowSleep(workflowCtx workflow.Context, duration time.Duration) error {
    return workflow.Sleep(workflowCtx, duration)
}

// In workflow; ctx has type workflow.Context:
    err := workflow.ExecuteActivity(ctx, myActivities.WorkflowSleep, duration).Get(ctx, nil)

错误：

"PanicError"："反映：输入参数太少的调用"

问题

是否可以在任何活动中使用workflow.Sleep？

Answer 1

是否可以使用工作流。在任何活动中睡觉？

不可以，不允许使用工作流。在活动代码中睡觉。

工作流。睡眠仅允许在工作流代码中使用。一般来说，workflow包中的所有API仅允许在工作流代码中使用。

工作流代码将在决策任务中执行，工作流线程/协程(特殊类型的goroutines)由Cadence管理。这就是< code>workflow包中的API的工作方式。如果没有决策任务和工作流线程/协同程序，这些API将无法正常工作。

另一方面，活动代码只是纯粹的普通代码，您应该使用常规的本地库或依赖项来实现逻辑。例如，您可以使用<代码>时间。活动代码中的睡眠。