chore: Cleanup

cloudquery · Sep 17, 2024 · 3342b0b · 3342b0b
1 parent 71f25b9
commit 3342b0b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/scheduler/queue/dispatcher.go b/scheduler/queue/dispatcher.go
@@ -288,6 +288,7 @@ func (d *Dispatcher) Dispatch(ctx context.Context, tableClients []TableClientPai
 			jobs <- item
 		}
 		close(jobs)
+		close(newJobs)
 	}()
 
 	go func() {