feat: Remove msgChan from func param

Author: Przemyslaw Stepien

scheduler/queue/scheduler.go

@@ -80,7 +80,7 @@ func NewShuffleQueueScheduler(logger zerolog.Logger, m *metrics.Metrics, seed in
 	return scheduler
 }
 
-func (d *Scheduler) Sync(ctx context.Context, tableClients []WorkUnit, resolvedResources chan<- *schema.Resource, msgChan chan<- message.SyncMessage) {
+func (d *Scheduler) Sync(ctx context.Context, tableClients []WorkUnit, resolvedResources chan<- *schema.Resource) {
 	if len(tableClients) == 0 {
 		return
 	}
@@ -105,7 +105,7 @@ func (d *Scheduler) Sync(ctx context.Context, tableClients []WorkUnit, resolvedR
 				d.invocationID,
 				d.deterministicCQID,
 				d.metrics,
-				msgChan,
+				d.msgChan,
 			).work(ctx, activeWorkSignal)
 			return nil
 		})