code: def in_transaction(connection_name: Optional[str] = None) -> BaseTransactionWrapper:
      
      connection = _get_connection(connection_name)
      return connection._in_transaction()
docs: Transaction context manager.
  
      You can run your code inside ``async with in_transaction():`` statement to run it
      into one transaction. If error occurs transaction will rollback.
  
      :param connection_name: name of connection to run with, optional if you have only
                              one db connection