fix(workflows/video): check if workflow ids exists before cancelling …

…workflow
Zibbp · Mar 20, 2024 · 9c93341 · 9c93341
1 parent 599e7dd
commit 9c93341
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 10 deletions.
diff --git a/cmd/server/main.go b/cmd/server/main.go
@@ -73,11 +73,6 @@ func Run() error {
 		zerolog.SetGlobalLevel(zerolog.InfoLevel)
 	}
 
-	//store, err := database.NewDatabase()
-	//if err != nil {
-	//	log.Error().Err(err).Msg("failed to create database connection")
-	//	return err
-	//}
 	database.InitializeDatabase(false)
 	store := database.DB()
 

diff --git a/internal/workflows/video.go b/internal/workflows/video.go
@@ -82,12 +82,14 @@ func cancelWorkflowAndCleanup(ctx context.Context, input dto.ArchiveVideoInput)
 		log.Error().Err(err).Msg("error getting queue item")
 		return err
 	}
-	log.Debug().Msgf("cancelling workflow: %s run: %s", q.WorkflowID, q.WorkflowRunID)
 	// cancel workflow
-	err = ganymedeTemporal.GetTemporalClient().Client.TerminateWorkflow(ctx, q.WorkflowID, q.WorkflowRunID, "no stream found")
-	if err != nil {
-		log.Error().Err(err).Msg("error cancelling workflow")
-		return err
+	if q.WorkflowID != "" && q.WorkflowRunID != "" {
+		log.Debug().Msgf("cancelling workflow: %s run: %s", q.WorkflowID, q.WorkflowRunID)
+		err = ganymedeTemporal.GetTemporalClient().Client.TerminateWorkflow(ctx, q.WorkflowID, q.WorkflowRunID, "no stream found")
+		if err != nil {
+			log.Error().Err(err).Msg("error cancelling workflow")
+			return err
+		}
 	}
 	// delete directory
 	path := fmt.Sprintf("/vods/%s/%s", input.Channel.Name, input.Vod.FolderName)