From 5e310c45077e1269602a3db453b7a4b69325122e Mon Sep 17 00:00:00 2001 From: Dylan Tinianov Date: Tue, 30 Jun 2026 14:15:52 -0400 Subject: [PATCH 1/4] Increase batch size --- core/services/chainlink/application.go | 1 + 1 file changed, 1 insertion(+) diff --git a/core/services/chainlink/application.go b/core/services/chainlink/application.go index 74168bdd70e..13e9d792750 100644 --- a/core/services/chainlink/application.go +++ b/core/services/chainlink/application.go @@ -393,6 +393,7 @@ func NewApplication(ctx context.Context, opts ApplicationOpts) (Application, err RetransmitEnabled: true, // host process owns retransmit EmitterConfig: &emitterCfg, Meter: meter, + BatchSize: 1000, // batch emitter config } pgStore := durableemitter.NewPgDurableEventStore(opts.DS) durableEmitter, setupErr := durableemitter.Setup(pgStore, durableCfg, globalLogger) From 9cb24af9794bc8f049077766e751340c166eb725 Mon Sep 17 00:00:00 2001 From: Dylan Tinianov Date: Tue, 30 Jun 2026 14:24:09 -0400 Subject: [PATCH 2/4] Build From 59e6ba5ed11b54f2555b6c27af35e83e66aa8ebb Mon Sep 17 00:00:00 2001 From: Dylan Tinianov Date: Tue, 30 Jun 2026 14:49:42 -0400 Subject: [PATCH 3/4] Increase batch size --- core/services/chainlink/application.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/core/services/chainlink/application.go b/core/services/chainlink/application.go index 13e9d792750..ec62ffda1c7 100644 --- a/core/services/chainlink/application.go +++ b/core/services/chainlink/application.go @@ -379,7 +379,9 @@ func NewApplication(ctx context.Context, opts ApplicationOpts) (Application, err // Wire DurableEmitter for persistent chip ingress delivery when enabled if cfg.Telemetry().DurableEmitterEnabled() && cfg.Telemetry().ChipIngressEndpoint() != "" { + maxBatchSize := 10_000 emitterCfg := durableemitter.DefaultConfig() + emitterCfg.RetransmitBatchSize = maxBatchSize emitterCfg.Metrics = &durableemitter.DurableEmitterMetricsConfig{} durableCfg := durableemitter.SetupConfig{ Endpoint: cfg.Telemetry().ChipIngressEndpoint(), @@ -393,7 +395,8 @@ func NewApplication(ctx context.Context, opts ApplicationOpts) (Application, err RetransmitEnabled: true, // host process owns retransmit EmitterConfig: &emitterCfg, Meter: meter, - BatchSize: 1000, // batch emitter config + BatchSize: maxBatchSize, // batch emitter config + MaxPublishTimeout: 10 * time.Second, } pgStore := durableemitter.NewPgDurableEventStore(opts.DS) durableEmitter, setupErr := durableemitter.Setup(pgStore, durableCfg, globalLogger) From cc75a3c3695c688c0626ae178606753eed33bc1f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tarc=C3=ADsio=20Zotelli=20Ferraz?= Date: Wed, 1 Jul 2026 15:43:52 -0300 Subject: [PATCH 4/4] update batch size --- core/services/chainlink/application.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/services/chainlink/application.go b/core/services/chainlink/application.go index ec62ffda1c7..028eb23a45c 100644 --- a/core/services/chainlink/application.go +++ b/core/services/chainlink/application.go @@ -379,7 +379,7 @@ func NewApplication(ctx context.Context, opts ApplicationOpts) (Application, err // Wire DurableEmitter for persistent chip ingress delivery when enabled if cfg.Telemetry().DurableEmitterEnabled() && cfg.Telemetry().ChipIngressEndpoint() != "" { - maxBatchSize := 10_000 + maxBatchSize := 1000 emitterCfg := durableemitter.DefaultConfig() emitterCfg.RetransmitBatchSize = maxBatchSize emitterCfg.Metrics = &durableemitter.DurableEmitterMetricsConfig{}