fixup! feat(router): avoid worker starvation during job pickup

rudderlabs · Nov 1, 2022 · 7af8db7 · 7af8db7
1 parent ae8332a
commit 7af8db7
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/router/internal/jobiterator/jobiterator.go b/router/internal/jobiterator/jobiterator.go
@@ -36,7 +36,7 @@ func WithLegacyOrderGroupKey(legacy bool) IteratorOptFn {
 }
 
 // Iterator is a job iterator with support for fetching more than the original set of jobs requested,
-// if case some of these jobs are discarded, according to the configured discarded percentage tolerance.
+// in case some of these jobs get discarded, according to the configured discarded percentage tolerance.
 type Iterator struct {
 	params                       jobsdb.GetQueryParamsT
 	maxQueries                   int

diff --git a/router/router.go b/router/router.go
@@ -1807,7 +1807,6 @@ func (rt *HandleT) readAndProcess() int {
 		time.Sleep(readSleep)
 		return 0
 	} else {
-		rt.logger.Debugf("[%v Router] :: router is enabled", rt.destName)
 		iteratorStats := iterator.Stats()
 		stats.Default.NewTaggedStat("router_iterator_stats_query_count", stats.GaugeType, stats.Tags{"destType": rt.destName}).Gauge(iteratorStats.QueryCount)
 		stats.Default.NewTaggedStat("router_iterator_stats_total_jobs", stats.GaugeType, stats.Tags{"destType": rt.destName}).Gauge(iteratorStats.TotalJobs)