perf: fix code error

jumpserver · Jan 15, 2025 · ff3bdce · ff3bdce
1 parent f2307fa
commit ff3bdce
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cmd/impl/jms.go b/cmd/impl/jms.go
@@ -181,7 +181,7 @@ func (j *JMServer) ScanRemainReplays(ctx context.Context, req *pb.RemainReplayRe
 }
 
 func (j *JMServer) sendStreamTask(ctx context.Context, stream pb.Service_DispatchTaskServer) {
-	taskChan := j.beat.GetTerminalTaskChan()
+	taskChan := j.beat.GetTerminalTaskChan(ctx)
 	for {
 		select {
 		case <-ctx.Done():