diff --git a/etl/pipeline/pipelineState.go b/etl/pipeline/pipelineState.go
index 9586282..06210b8 100644
--- 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)