We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0b70525 commit f1704d4Copy full SHA for f1704d4
1 file changed
worker/internal/cmds/worker/serve/serve.go
@@ -382,7 +382,10 @@ func serve(ctx context.Context) error {
382
}
383
384
maxIterations := 100
385
- pageLimit := 100_000
+ pageLimit := viper.GetInt("MAX_TABLE_SYNC_PAGE_LIMIT")
386
+ if pageLimit <= 0 {
387
+ pageLimit = 100_000
388
+ }
389
streamManager := benthosstream.NewBenthosStreamManager()
390
tablesync_workflow_register.Register(
391
w,
0 commit comments