diff --git a/controller/video_proxy.go b/controller/video_proxy.go
index ec6189189..5532802ec 100644
--- a/controller/video_proxy.go
+++ b/controller/video_proxy.go
@@ -35,7 +35,8 @@ func VideoProxy(c *gin.Context) {
 		return
 	}
 
-	task, exists, err := model.GetByOnlyTaskId(taskID)
+	userID := c.GetInt("id")
+	task, exists, err := model.GetByTaskId(userID, taskID)
 	if err != nil {
 		logger.LogError(c.Request.Context(), fmt.Sprintf("Failed to query task %s: %s", taskID, err.Error()))
 		videoProxyError(c, http.StatusInternalServerError, "server_error", "Failed to query task")