chore: Support taskExecutionId

Signed-off-by: Javier Aliaga <[email protected]>

Author: javier-aliaga

go.mod

@@ -4,7 +4,7 @@ go 1.24.2
 
 require (
 	github.com/dapr/dapr v1.15.5
-	github.com/dapr/durabletask-go v0.6.5
+	github.com/dapr/durabletask-go v0.7.3-0.20250705135742-20fd7583dc03
 	github.com/go-chi/chi/v5 v5.1.0
 	github.com/golang/mock v1.6.0
 	github.com/google/uuid v1.6.0
@@ -16,7 +16,7 @@ require (
 
 require (
 	github.com/cenkalti/backoff/v4 v4.3.0 // indirect
-	github.com/dapr/kit v0.15.2 // indirect
+	github.com/dapr/kit v0.15.3-0.20250616160611-598b032bce69 // indirect
 	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
 	github.com/go-logr/logr v1.4.2 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect

go.sum

@@ -2,10 +2,10 @@ github.com/cenkalti/backoff/v4 v4.3.0 h1:MyRJ/UdXutAwSAT+s3wNd7MfTIcy71VQueUuFK3
 github.com/cenkalti/backoff/v4 v4.3.0/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyYozVcomhLiZE=
 github.com/dapr/dapr v1.15.5 h1:bkCmcQQfaQ5C49P3l0elCzDr4/Oja5kitM3jStY+2RY=
 github.com/dapr/dapr v1.15.5/go.mod h1:wwopO8AD9CZOgVj4bsdXNmeQujMo0v3MLAqeaX+gb00=
-github.com/dapr/durabletask-go v0.6.5 h1:aWcxMfYudojpgRjJRdUr7yyZ7rGcvLtWXUuA4cGHBR0=
-github.com/dapr/durabletask-go v0.6.5/go.mod h1:nTZ5fCbJLnZbVdi6Z2YxdDF1OgQZL3LroogGuetrwuA=
-github.com/dapr/kit v0.15.2 h1:5H9IhKScU/SpE2Hxvr5vUlmYN1e2MJN15RoT8/KSziU=
-github.com/dapr/kit v0.15.2/go.mod h1:HwFsBKEbcyLanWlDZE7u/jnaDCD/tU+n3pkFNUctQNw=
+github.com/dapr/durabletask-go v0.7.3-0.20250705135742-20fd7583dc03 h1:/Sl6sJE3jdPh96KfGShshIF0xZlAjN36Buq9mcNFV7Q=
+github.com/dapr/durabletask-go v0.7.3-0.20250705135742-20fd7583dc03/go.mod h1:0Ts4rXp74JyG19gDWPcwNo5V6NBZzhARzHF5XynmA7Q=
+github.com/dapr/kit v0.15.3-0.20250616160611-598b032bce69 h1:I1Uoy3fn906AZZdG8+n8fHitgY7Wn9c+smz4WQdOy1Q=
+github.com/dapr/kit v0.15.3-0.20250616160611-598b032bce69/go.mod h1:6w2Pr38zOAtBn+ld/jknwI4kgMfwanCIcFVnPykdPZQ=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=

workflow/activity_context.go

@@ -36,6 +36,10 @@ func (wfac *ActivityContext) Context() context.Context {
 	return wfac.ctx.Context()
 }
 
+func (wfac *ActivityContext) GetTaskExecutionID() string {
+	return wfac.ctx.GetTaskExecutionID()
+}
+
 type callActivityOption func(*callActivityOptions) error
 
 type callActivityOptions struct {

workflow/activity_context_test.go

@@ -28,8 +28,17 @@ import (
 )
 
 type testingTaskActivityContext struct {
-	inputBytes []byte
-	ctx        context.Context
+	inputBytes      []byte
+	ctx             context.Context
+	taskExecutionID string
+}
+
+func (t *testingTaskActivityContext) GetTaskID() int32 {
+	return 0
+}
+
+func (t *testingTaskActivityContext) GetTaskExecutionID() string {
+	return t.taskExecutionID
 }
 
 func (t *testingTaskActivityContext) GetInput(v any) error {
@@ -119,3 +128,19 @@ func TestMarshalData(t *testing.T) {
 		assert.Equal(t, []byte{0x22, 0x74, 0x65, 0x73, 0x74, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x22}, out)
 	})
 }
+
+func TestTaskExecutionID(t *testing.T) {
+	ac := ActivityContext{ctx: &testingTaskActivityContext{ctx: t.Context(), taskExecutionID: "testTaskExecutionID"}}
+
+	t.Run("test getTaskExecutionID", func(t *testing.T) {
+		assert.Equal(t, "testTaskExecutionID", ac.GetTaskExecutionID())
+	})
+}
+
+func TestTaskID(t *testing.T) {
+	ac := ActivityContext{ctx: &testingTaskActivityContext{ctx: t.Context(), taskExecutionID: "testTaskExecutionID"}}
+
+	t.Run("test getTaskID", func(t *testing.T) {
+		assert.EqualValues(t, 0, ac.ctx.GetTaskID())
+	})
+}