airflow/hooks/dbapi_hook.py
def set_autocommit(self, conn, autocommit):
        """
        Sets the autocommit flag on the connection
        """
        if not self.supports_autocommit and autocommit:
            self.log.warn(
                ("%s connection doesn't support "
                 "autocommit but autocommit activated."),
                getattr(self, self.conn_name_attr))
        conn.autocommit = autocommit
def set_autocommit(self, conn, autocommit):
        if not self.supports_autocommit and autocommit:
            self.log.warn(
                ("%s connection doesn't support "
                 "autocommit but autocommit activated."),
                getattr(self, self.conn_name_attr))
        conn.autocommit = autocommit
def set_autocommit ( self , conn , autocommit ) : if not self . supports_autocommit and autocommit : self . log . warn ( ( "%s connection doesn't support " "autocommit but autocommit activated." ) , getattr ( self , self . conn_name_attr ) ) conn . autocommit = autocommit
Sets the autocommit flag on the connection
Sets the autocommit flag on the connection