Ensure workflow task only includes events that it should

cschleiden · web-flow · commit dd6ff6da236e · 2022-04-07T18:54:27.000Z
diff --git a/backend/redis/workflow.go b/backend/redis/workflow.go
@@ -98,7 +98,7 @@ func (rb *redisBackend) GetWorkflowTask(ctx context.Context) (*task.Workflow, er
 	// New Events
 	newEvents := make([]history.Event, 0)
 
-	msgs, err = rb.rdb.XRange(ctx, pendingEventsKey(instanceTask.ID), "-", "+").Result()
+	msgs, err = rb.rdb.XRange(ctx, pendingEventsKey(instanceTask.ID), "-", instanceTask.Data.LastPendingEventMessageID).Result()
 	if err != nil {
 		return nil, errors.Wrap(err, "could not read event stream")
 	}

Original file line number	Diff line number	Diff line change
`@@ -98,7 +98,7 @@ func (rb redisBackend) GetWorkflowTask(ctx context.Context) (task.Workflow, er`
`98`	`98`	`// New Events`
`99`	`99`	`newEvents := make([]history.Event, 0)`
`100`	`100`
`101`		`- msgs, err = rb.rdb.XRange(ctx, pendingEventsKey(instanceTask.ID), "-", "+").Result()`
	`101`	`+ msgs, err = rb.rdb.XRange(ctx, pendingEventsKey(instanceTask.ID), "-", instanceTask.Data.LastPendingEventMessageID).Result()`
`102`	`102`	`if err != nil {`
`103`	`103`	`return nil, errors.Wrap(err, "could not read event stream")`
`104`	`104`	`}`