add escape for no after effects

meshtrade · Nov 11, 2024 · 1b68c79 · 1b68c79
1 parent 5236c18
commit 1b68c79
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/etl/pipeline/pipelineState.go b/etl/pipeline/pipelineState.go
@@ -23,8 +23,11 @@ func (p *PipelineState) RegisterAfterEffect(afterEffect AfterEffect) {
 }
 
 func (p *PipelineState) RunAfterEffects(ctx context.Context) error {
-	errGroup := new(errgroup.Group)
+	if len(p.afterEffects) == 0 {
+		return nil
+	}
 
+	errGroup := new(errgroup.Group)
 	for _, afterEffect := range p.afterEffects {
 		errGroup.Go(func() error {
 			return afterEffect(ctx)