Update flyteplugins

pkg/controller/nodes/task/catalog/datacatalog/transformer.go

@@ -11,9 +11,7 @@ import (
 	"github.com/flyteorg/flyteidl/gen/pb-go/flyteidl/core"
 	"github.com/flyteorg/flyteidl/gen/pb-go/flyteidl/datacatalog"
 	"github.com/flyteorg/flyteplugins/go/tasks/pluginmachinery/catalog"
-
 	"github.com/flyteorg/flytepropeller/pkg/compiler/validators"
-
 	"github.com/flyteorg/flytestdlib/pbhash"
 )
 
@@ -116,72 +114,12 @@ func generateTaskSignatureHash(ctx context.Context, taskInterface core.TypedInte
 	return fmt.Sprintf("%v-%v", inputHashString, outputHashString), nil
 }
 
-// Hashify a literal, in other words, produce a new literal where the corresponding value is removed in case
-// the literal hash is set.
-func hashify(literal *core.Literal) *core.Literal {
-	// Two recursive cases:
-	//   1. A collection of literals or
-	//   2. A map of literals
-
-	if literal.GetCollection() != nil {
-		literals := literal.GetCollection().Literals
-		literalsHash := make([]*core.Literal, 0)
-		for _, lit := range literals {
-			literalsHash = append(literalsHash, hashify(lit))
-		}
-		return &core.Literal{
-			Value: &core.Literal_Collection{
-				Collection: &core.LiteralCollection{
-					Literals: literalsHash,
-				},
-			},
-		}
-	}
-	if literal.GetMap() != nil {
-		literalsMap := make(map[string]*core.Literal)
-		for key, lit := range literal.GetMap().Literals {
-			literalsMap[key] = hashify(lit)
-		}
-		return &core.Literal{
-			Value: &core.Literal_Map{
-				Map: &core.LiteralMap{
-					Literals: literalsMap,
-				},
-			},
-		}
-	}
-
-	// And a base case that consists of a scalar, where the hash might be set
-	if literal.GetHash() != "" {
-		return &core.Literal{
-			Hash: literal.GetHash(),
-		}
-	}
-	return literal
-}
-
 // Generate a tag by hashing the input values
 func GenerateArtifactTagName(ctx context.Context, inputs *core.LiteralMap) (string, error) {
-	if inputs == nil || len(inputs.Literals) == 0 {
-		inputs = &emptyLiteralMap
-	}
-
-	// Hashify, i.e. generate a copy of the literal map where each literal value is removed
-	// in case the corresponding hash is set.
-	hashifiedLiteralMap := make(map[string]*core.Literal, len(inputs.Literals))
-	for name, literal := range inputs.Literals {
-		hashifiedLiteralMap[name] = hashify(literal)
-	}
-	hashifiedInputs := &core.LiteralMap{
-		Literals: hashifiedLiteralMap,
-	}
-
-	inputsHash, err := pbhash.ComputeHash(ctx, hashifiedInputs)
+	hashString, err := catalog.HashLiteralMap(ctx, inputs)
 	if err != nil {
 		return "", err
 	}
-
-	hashString := base64.RawURLEncoding.EncodeToString(inputsHash)
 	tag := fmt.Sprintf("%s-%s", cachedTaskTag, hashString)
 	return tag, nil
 }