fix: Dynamodb certification tests are failing

Probably stale data

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

Author: javier-aliaga

state/aws/dynamodb/dynamodb.go

@@ -477,7 +477,7 @@ func (d *StateStore) Multi(ctx context.Context, request *state.TransactionalStat
 				return fmt.Errorf("dynamodb error: failed to marshal value for key %s: %w", req.Key, err)
 			}
 			twi.Put = pd.ToPut()
-
+			twi.ConditionCheck.ReturnValuesOnConditionCheckFailure = types.ReturnValuesOnConditionCheckFailureAllOld
 		case state.DeleteRequest:
 			twi.Delete = &types.Delete{
 				TableName: ptr.Of(d.table),
@@ -490,6 +490,7 @@ func (d *StateStore) Multi(ctx context.Context, request *state.TransactionalStat
 		}
 		twinput.TransactItems = append(twinput.TransactItems, twi)
 	}
+
 	_, err := d.dynamodbClient.TransactWriteItems(ctx, twinput)
 
 	return err

tests/certification/state/aws/dynamodb/dynamodb_test.go

@@ -19,19 +19,20 @@ import (
 	"testing"
 	"time"
 
-	dynamodb "github.com/dapr/components-contrib/state/aws/dynamodb"
+	"github.com/dapr/components-contrib/state/aws/dynamodb"
 	"github.com/dapr/components-contrib/tests/certification/embedded"
 	"github.com/dapr/components-contrib/tests/certification/flow"
 	"github.com/dapr/go-sdk/client"
 
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+
 	secretstore_env "github.com/dapr/components-contrib/secretstores/local/env"
 	"github.com/dapr/components-contrib/tests/certification/flow/sidecar"
 	secretstores_loader "github.com/dapr/dapr/pkg/components/secretstores"
 	state_loader "github.com/dapr/dapr/pkg/components/state"
 	dapr_testing "github.com/dapr/dapr/pkg/testing"
 	"github.com/dapr/kit/logger"
-	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/require"
 )
 
 const (
@@ -139,6 +140,12 @@ func TestAWSDynamoDBStorage(t *testing.T) {
 			err = cl.SaveState(ctx, statestore, kdel, []byte(kdel), nil)
 			require.NoError(t, err)
 
+			err = cl.DeleteState(ctx, statestore, ktx1, nil)
+			require.NoError(t, err)
+
+			err = cl.DeleteState(ctx, statestore, ktx2, nil)
+			require.NoError(t, err)
+
 			err = cl.ExecuteStateTransaction(ctx, statestore, nil, []*client.StateOperation{
 				{
 					Type: client.StateOperationTypeUpsert,