diff --git a/pkg/worker/context.go b/pkg/worker/context.go index deb0fc1cc..684a39d02 100644 --- a/pkg/worker/context.go +++ b/pkg/worker/context.go @@ -49,6 +49,8 @@ type HatchetContext interface { StepRunId() string + StepId() string + WorkflowRunId() string Log(message string) @@ -208,6 +210,10 @@ func (h *hatchetContext) StepRunId() string { return h.a.StepRunId } +func (h *hatchetContext) StepId() string { + return h.a.StepId +} + func (h *hatchetContext) WorkflowRunId() string { return h.a.WorkflowRunId } diff --git a/pkg/worker/middleware_test.go b/pkg/worker/middleware_test.go index dd18571e2..7e2ce97fe 100644 --- a/pkg/worker/middleware_test.go +++ b/pkg/worker/middleware_test.go @@ -55,6 +55,10 @@ func (c *testHatchetContext) StepRunId() string { panic("not implemented") } +func (c *testHatchetContext) StepId() string { + panic("not implemented") +} + func (c *testHatchetContext) WorkflowRunId() string { panic("not implemented") }