Add blob back

Signed-off-by: Hongxin Liang <[email protected]>
flyteorg · Oct 11, 2023 · b246564 · b246564
1 parent f6e7942
commit b246564
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/flytekit-scala_2.13/src/main/scala/org/flyte/flytekitscala/SdkBindingDataConverters.scala b/flytekit-scala_2.13/src/main/scala/org/flyte/flytekitscala/SdkBindingDataConverters.scala
@@ -172,6 +172,11 @@ object SdkBindingDataConverters {
               jf.Function.identity()
             )
         }
+      case LiteralType.Kind.BLOB_TYPE =>
+        TypeCastingResult(
+          SdkScalaLiteralTypes.blobs(lt.blobType()),
+          jf.Function.identity()
+        )
       case LiteralType.Kind.SCHEMA_TYPE => ??? // TODO not yet supported
       case LiteralType.Kind.COLLECTION_TYPE =>
         val TypeCastingResult(convertedElementType, convFunction) = toScalaType(
@@ -256,6 +261,11 @@ object SdkBindingDataConverters {
               jf.Function.identity()
             )
         }
+      case LiteralType.Kind.BLOB_TYPE =>
+        TypeCastingResult(
+          SdkJavaLiteralTypes.blobs(lt.blobType()),
+          jf.Function.identity()
+        )
       case LiteralType.Kind.SCHEMA_TYPE =>
         ??? // TODO do we support schema type?
       case LiteralType.Kind.COLLECTION_TYPE =>