diff --git a/pkg/handler/repositories.go b/pkg/handler/repositories.go
index e6fe4b98e..d09d5137f 100644
--- a/pkg/handler/repositories.go
+++ b/pkg/handler/repositories.go
@@ -612,6 +612,10 @@ func (rh *RepositoryHandler) createUpload(c echo.Context) error {
 
 	existingUUID, completedChunks, err := ph.DaoRegistry.Uploads.GetExistingUploadIDAndCompletedChunks(c.Request().Context(), orgId, req.Sha256, req.ChunkSize)
 
+	if err != nil {
+		return err
+	}
+
 	if existingUUID != "" {
 		resp := &api.UploadResponse{
 			UploadUuid:         &existingUUID,
diff --git a/test/integration/pulp_upload_test.go b/test/integration/pulp_upload_test.go
index f7dd8d0a4..0a7b6dd5c 100644
--- a/test/integration/pulp_upload_test.go
+++ b/test/integration/pulp_upload_test.go
@@ -298,7 +298,9 @@ func (s *UploadSuite) CreateUploadRequestInternal(size int64) zest.UploadRespons
 	t := s.T()
 	// Create an upload
 	createRequest := api.CreateUploadRequest{
-		Size: size,
+		ChunkSize: 16000,
+		Sha256:    "UploadSha256" + fmt.Sprint(size),
+		Size:      size,
 	}
 	var uploadResponse zest.UploadResponse
 
@@ -342,7 +344,9 @@ func (s *UploadSuite) UploadChunksPublic(fileContent []byte, uploadResponse api.
 func (s *UploadSuite) CreateUploadRequestPublic(size int64) api.UploadResponse {
 	t := s.T()
 	createRequest := api.CreateUploadRequest{
-		Size: size,
+		ChunkSize: 16000,
+		Sha256:    "UploadSha256" + fmt.Sprint(size),
+		Size:      size,
 	}
 	var uploadResponse api.UploadResponse