SQLAlchemy asyncpg

sqla_asyncpg_orig_exc.py

  """
  Just a note where to find original asyncpg exception object wrapped by SQLAlchemy
  """
  
  
  try:
      created_record = await db.scalar(insert(Model).values(**data_in.model_dump()).returning(Model))
  except IntegrityError as err:
      if isinstance(err.orig.__cause__, UniqueViolationError):
          raise RecordAlreadyExists()