From be3a7695727b01bacc9fb9b7553f05516056149e Mon Sep 17 00:00:00 2001 From: brucexc Date: Tue, 4 Jun 2024 17:40:08 -0400 Subject: [PATCH] fix: add federated lens --- internal/node/monitor/monitor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/node/monitor/monitor.go b/internal/node/monitor/monitor.go index d849b98a..17f953a9 100644 --- a/internal/node/monitor/monitor.go +++ b/internal/node/monitor/monitor.go @@ -27,7 +27,7 @@ type CheckpointState struct { func (m *Monitor) MonitorWorkerStatus(ctx context.Context) error { var wg sync.WaitGroup - errChan := make(chan error, len(m.config.Component.Decentralized)+len(m.config.Component.RSS)) + errChan := make(chan error, len(m.config.Component.Decentralized)+len(m.config.Component.RSS)+len(m.config.Component.Federated)) processWorker := func(w *config.Module, processFunc func(context.Context, *config.Module) error) { wg.Add(1)