fix conversion from proto to metadata

block · May 27, 2024 · 2e46f92 · 2e46f92
1 parent fffef5d
commit 2e46f92
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/backend/schema/protobuf_dec.go b/backend/schema/protobuf_dec.go
@@ -136,6 +136,19 @@ func metadataToSchema(s *schemapb.Metadata) Metadata {
 			Alias: s.Alias.Alias,
 		}
 
+	case *schemapb.Metadata_Retry:
+		var count *int
+		if s.Retry.Count != nil {
+			countValue := int(*s.Retry.Count)
+			count = &countValue
+		}
+		return &MetadataRetry{
+			Pos:        posFromProto(s.Retry.Pos),
+			Count:      count,
+			MinBackoff: s.Retry.MinBackoff,
+			MaxBackoff: s.Retry.MaxBackoff,
+		}
+
 	default:
 		panic(fmt.Sprintf("unhandled metadata type: %T", s))
 	}