Skip to content

Commit

Permalink
add back newlines
Browse files Browse the repository at this point in the history
  • Loading branch information
AdamHaffar committed Dec 11, 2024
1 parent 5054c81 commit 7b2de1a
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions pkg/lifecycle/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -393,10 +393,12 @@ func (s *Service) buildNodes(ctx context.Context, pl *pipeline.Instance) ([]stre
if len(sourceNodes) == 0 {
return nil, cerrors.New("can't build pipeline without any source connectors")
}

processorNodes, err := s.buildProcessorNodes(ctx, pl, pl.ProcessorIDs, &fanIn, &fanOut)
if err != nil {
return nil, cerrors.Errorf("could not build processor nodes: %w", err)
}

destinationNodes, err := s.buildDestinationNodes(ctx, pl, &fanOut)
if err != nil {
return nil, cerrors.Errorf("could not build destination nodes: %w", err)
Expand Down

0 comments on commit 7b2de1a

Please sign in to comment.