(self, query)
Executes query with timestamp from parts if comparing start_time field.
Executes query with timestamp from parts if comparing start_time field.
Executes query with timestamp from parts if comparing start_time field .
def execute_query_raw(self, query):
        """
        Executes query with timestamp from parts if comparing start_time field.
        """
        with closing(self._conn.cursor()) as cursor:
            cursor.execute(query)

            if cursor.rowcount is None or cursor.rowcount < 1:
                self.log.debug("Failed to fetch records from query: `%s`", query)
                return []
            return cursor.fetchall()
def execute_query_raw ( self , query ) : with closing ( self . _conn . cursor ( ) ) as cursor : cursor . execute ( query ) if cursor . rowcount is None or cursor . rowcount < 1 : self . log . debug ( "Failed to fetch records from query: `%s`" , query ) return [ ] return cursor . fetchall ( )