chore: Cleanup

cloudquery · Sep 17, 2024 · 71f25b9 · 71f25b9
1 parent 25ff3d2
commit 71f25b9
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/scheduler/queue/priorityqueue.go b/scheduler/queue/priorityqueue.go
@@ -75,7 +75,6 @@ func newQueue(tableClients []TableClientPair) *priorityQueue {
 }
 
 type ConcurrentQueue struct {
-	maxSize                   int
 	queue                     *priorityQueue
 	lock                      sync.Mutex
 	itemCountByTableAndClient map[string]int
@@ -88,7 +87,6 @@ func tableClientID(tableClient TableClientPair) string {
 func NewConcurrentQueue(tableClients []TableClientPair) *ConcurrentQueue {
 	cq := ConcurrentQueue{
 		queue:                     newQueue(tableClients),
-		maxSize:                   defaultMaxSize,
 		itemCountByTableAndClient: make(map[string]int),
 	}
 	for _, tc := range tableClients {