commit provisioning transaction before starting pipeline (#1759)

pkg/provisioning/service.go

@@ -233,17 +233,23 @@ func (s *Service) provisionPipeline(ctx context.Context, cfg config.Pipeline) er
 		return cerrors.Errorf("invalid pipeline config: %w", err)
 	}
 
-	txn, ctx, err := s.db.NewTransaction(ctx, true)
+	txn, importCtx, err := s.db.NewTransaction(ctx, true)
 	if err != nil {
 		return cerrors.Errorf("could not create db transaction: %w", err)
 	}
 	defer txn.Discard()
 
-	err = s.Import(ctx, cfg)
+	err = s.Import(importCtx, cfg)
 	if err != nil {
 		return cerrors.Errorf("could not import pipeline: %w", err)
 	}
 
+	// commit db transaction
+	err = txn.Commit()
+	if err != nil {
+		return cerrors.Errorf("could not commit db transaction: %w", err)
+	}
+
 	// check if pipeline should be running
 	if cfg.Status == config.StatusRunning {
 		// TODO set status and let the pipeline service start it
@@ -253,12 +259,6 @@ func (s *Service) provisionPipeline(ctx context.Context, cfg config.Pipeline) er
 		}
 	}
 
-	// commit db transaction
-	err = txn.Commit()
-	if err != nil {
-		return cerrors.Errorf("could not commit db transaction: %w", err)
-	}
-
 	return nil
 }