(cls, connection: Connection)
Roll back the given connection.
Roll back the given connection.
Roll back the given connection .
def _rollback(cls, connection: Connection) -> None:
        """Roll back the given connection."""
        if connection.transaction_open is False:
            raise dbt.exceptions.InternalException(
                f'Tried to rollback transaction on connection '
                f'"{connection.name}", but it does not have one open!'
            )

        fire_event(Rollback(conn_name=connection.name))
        cls._rollback_handle(connection)

        connection.transaction_open = False
def _rollback ( cls , connection : Connection ) -> None : if connection . transaction_open is False : raise dbt . exceptions . InternalException ( f'Tried to rollback transaction on connection ' f'"{connection.name}", but it does not have one open!' ) fire_event ( Rollback ( conn_name = connection . name ) ) cls . _rollback_handle ( connection ) connection . transaction_open = False