This is my current code, it supposed to start a transaction in the update method that used other services.

  async update(authContext: AuthContext, id: string, updatePortfolioDto: UpdatePortfolioDto, isSaved = false): Promise<Portfolio> {

    const queryRunner = this.dataSource.createQueryRunner();

  await queryRunner.connect();
  await queryRunner.startTransaction();
  try{
    await this.sleeveService.deleteForPortfolio(authContext, id);
    const updatedPortfolio = this.portfoliosRepository.update(id, portfolio);
    await queryRunner.commitTransaction();
    return updatedPortfolio

  }catch(err){
    await queryRunner.rollbackTransaction();
  }finally{
    await queryRunner.release();
  }
  }

As you can see, I am calling a method from another sevice and repository.

For example deleteForPortfolio method in the sleeveservice is

export class TypeOrmSleeveRepository implements ISleevesRepository {
  private readonly logger = new Logger(TypeOrmSleeveRepository.name);

  constructor(@InjectRepository(Sleeve) private readonly sleeveRepository: Repository<Sleeve>) {}

  deleteForPortfolio(authContext: AuthContext, portfolioId: string) {
    this.sleeveRepository
      .createQueryBuilder('sleeve')
      .delete()
      .where('sleeve.portfolioId = :portfolioId', { portfolioId })
      .andWhere('sleeve.tenantId = :tenantId', { tenantId: authContext.tenantId })
      .execute();
  }
}

and the portfolio update method is

  async update(id: string, portfolio: Portfolio): Promise<Portfolio> {
    try {
      const updatedPortfolio = await this.portfolioRepository.preload({
        id,
        ...portfolio
      });

      if (!updatedPortfolio) {
        this.logger.warn(`Portfolio with ID ${id} not found`);
        throw new NotFoundException(`Portfolio with ID ${id} not found`);
      }
      const savedPortfolio = await this.portfolioRepository.save(updatedPortfolio);
      this.logger.log(`Updated Portfolio with ID ${id}`);
      return savedPortfolio;
    } catch (error) {
      if (error instanceof NotFoundException) {
        throw error;
      }
      this.logger.error(`Error updating portfolio with ID ${id}: ${error.message}`, error.stack);
      throw error;
    }
  }

Currently my code does not work. How can I fix this please ?