add VideoUpgradeFailed staus

manager/manager.go

@@ -93,6 +93,7 @@ var SyncStatuses = []string{StatusPending, StatusPendingEmail, StatusPendingUpgr
 const (
 	VideoStatusPublished     = "published"
 	VideoStatusFailed        = "failed"
+	VideoStatusUpgradeFailed = "upgradefailed"
 	VideoStatusUnpublished   = "unpublished"
 )
 

manager/ytsync.go

@@ -711,9 +711,12 @@ func (s *Sync) startWorker(workerNum int) {
 						existingClaimSize = &existingClaim.Size
 					}
 				}
-
+				videoStatus := VideoStatusFailed
+				if strings.Contains(err.Error(), "upgrade failed") {
+					videoStatus = VideoStatusUpgradeFailed
+				}
 				s.AppendSyncedVideo(v.ID(), false, err.Error(), "")
-				err = s.Manager.apiConfig.MarkVideoStatus(s.YoutubeChannelID, v.ID(), VideoStatusFailed, existingClaimID, existingClaimName, err.Error(), existingClaimSize, 0)
+				err = s.Manager.apiConfig.MarkVideoStatus(s.YoutubeChannelID, v.ID(), videoStatus, existingClaimID, existingClaimName, err.Error(), existingClaimSize, 0)
 				if err != nil {
 					SendErrorToSlack("Failed to mark video on the database: %s", err.Error())
 				}

sources/youtubeVideo.go

@@ -378,7 +378,7 @@ func (v *YoutubeVideo) Sync(daemon *jsonrpc.Client, params SyncParams, existingV
 	v.lbryChannelID = params.ChannelID
 	if reprocess && existingVideoData != nil && existingVideoData.Published {
 		summary, err := v.reprocess(daemon, params, existingVideoData)
-		return summary, err
+		return summary, errors.Prefix("upgrade failed", err)
 	}
 	return v.downloadAndPublish(daemon, params)
 }