Store instance in activity queue

Author: cschleiden

backend/redis/activity.go

@@ -19,7 +19,7 @@ func (rb *redisBackend) GetActivityTask(ctx context.Context) (*task.Activity, er
 	}
 
 	return &task.Activity{
-		WorkflowInstance: core.NewWorkflowInstance(activityTask.Data.InstanceID, activityTask.Data.ExecutionID),
+		WorkflowInstance: activityTask.Data.Instance,
 		ID:               activityTask.TaskID, // Use the queue generated ID here
 		Event:            activityTask.Data.Event,
 	}, nil

backend/redis/redis.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/cschleiden/go-workflows/backend"
 	"github.com/cschleiden/go-workflows/backend/redis/taskqueue"
+	"github.com/cschleiden/go-workflows/internal/core"
 	"github.com/cschleiden/go-workflows/internal/history"
 	"github.com/cschleiden/go-workflows/log"
 	"github.com/go-redis/redis/v8"
@@ -86,10 +87,9 @@ type redisBackend struct {
 }
 
 type activityData struct {
-	InstanceID  string        `json:"instance_id,omitempty"`
-	ExecutionID string        `json:"execution_id,omitempty"`
-	ID          string        `json:"id,omitempty"`
-	Event       history.Event `json:"event,omitempty"`
+	Instance *core.WorkflowInstance `json:"instance,omitempty"`
+	ID       string                 `json:"id,omitempty"`
+	Event    history.Event          `json:"event,omitempty"`
 }
 
 type workflowTaskData struct {

backend/redis/workflow.go

@@ -215,9 +215,9 @@ func (rb *redisBackend) CompleteWorkflowTask(ctx context.Context, taskID string,
 	// Store activity data
 	for _, activityEvent := range activityEvents {
 		if _, err := rb.activityQueue.Enqueue(ctx, activityEvent.ID, &activityData{
-			InstanceID: instance.InstanceID,
-			ID:         activityEvent.ID,
-			Event:      activityEvent,
+			Instance: instance,
+			ID:       activityEvent.ID,
+			Event:    activityEvent,
 		}); err != nil {
 			return errors.Wrap(err, "could not queue activity task")
 		}