diff options
| -rw-r--r-- | syz-cluster/controller/processor.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/syz-cluster/controller/processor.go b/syz-cluster/controller/processor.go index 6a36a7551..1493b5852 100644 --- a/syz-cluster/controller/processor.go +++ b/syz-cluster/controller/processor.go @@ -120,6 +120,9 @@ func (sp *SeriesProcessor) seriesRunner(ctx context.Context, ch <-chan *db.Sessi var session *db.Session select { case session = <-ch: + if session == nil { + return + } case <-ctx.Done(): return } |