fix: Return all values

javier-aliaga · javier-aliaga · commit 79e2518a508a · 2025-10-23T15:25:48.000+02:00
Signed-off-by: Javier Aliaga &lt;javier@diagrid.io&gt;
diff --git a/state/aws/dynamodb/dynamodb.go b/state/aws/dynamodb/dynamodb.go
@@ -479,7 +479,12 @@ func (d *StateStore) Multi(ctx context.Context, request *state.TransactionalStat
 			}
 			twi.Put = pd.ToPut()
 			if twi.Put.ConditionExpression != nil {
-				twi.ConditionCheck.ReturnValuesOnConditionCheckFailure = types.ReturnValuesOnConditionCheckFailureAllOld
+				twi.ConditionCheck = &types.ConditionCheck{
+					Key:                                 twi.Put.Item,
+					ConditionExpression:                 twi.Put.ConditionExpression,
+					TableName:                           ptr.Of(d.table),
+					ReturnValuesOnConditionCheckFailure: types.ReturnValuesOnConditionCheckFailureAllOld,
+				}
 			}
 		case state.DeleteRequest:
 			twi.Delete = &types.Delete{

Original file line number	Diff line number	Diff line change
`@@ -479,7 +479,12 @@ func (d StateStore) Multi(ctx context.Context, request state.TransactionalStat`
`479`	`479`	`}`
`480`	`480`	`twi.Put = pd.ToPut()`
`481`	`481`	`if twi.Put.ConditionExpression != nil {`
`482`		`- twi.ConditionCheck.ReturnValuesOnConditionCheckFailure = types.ReturnValuesOnConditionCheckFailureAllOld`
	`482`	`+ twi.ConditionCheck = &types.ConditionCheck{`
	`483`	`+ Key: twi.Put.Item,`
	`484`	`+ ConditionExpression: twi.Put.ConditionExpression,`
	`485`	`+ TableName: ptr.Of(d.table),`
	`486`	`+ ReturnValuesOnConditionCheckFailure: types.ReturnValuesOnConditionCheckFailureAllOld,`
	`487`	`+ }`
`483`	`488`	`}`
`484`	`489`	`case state.DeleteRequest:`
`485`	`490`	`twi.Delete = &types.Delete{`