google/cloud/bigquery/dbapi/cursor.py
def _try_fetch(self, size=None):
        """Try to start fetching data, if not yet started.

        Mutates self to indicate that iteration has started.
        """
        if self._query_job is None:
            raise exceptions.InterfaceError(
                'No query results: execute() must be called before fetch.')

        is_dml = (
            self._query_job.statement_type
            and self._query_job.statement_type.upper() != 'SELECT')
        if is_dml:
            self._query_data = iter([])
            return

        if self._query_data is None:
            client = self.connection._client
            # TODO(tswast): pass in page size to list_rows based on arraysize
            rows_iter = client.list_rows(
                self._query_job.destination,
                selected_fields=self._query_job.query_results().schema)
            self._query_data = iter(rows_iter)
Try to start fetching data, if not yet started.

        Mutates self to indicate that iteration has started.
        
Try to start fetching data, if not yet started.
Mutates self to indicate that iteration has started.
Try to start fetching data if not yet started . Mutates self to indicate that iteration has started .
def _try_fetch(self, size=None):
        if self._query_job is None:
            raise exceptions.InterfaceError(
                'No query results: execute() must be called before fetch.')
        is_dml = (
            self._query_job.statement_type
            and self._query_job.statement_type.upper() != 'SELECT')
        if is_dml:
            self._query_data = iter([])
            return
        if self._query_data is None:
            client = self.connection._client
            rows_iter = client.list_rows(
                self._query_job.destination,
                selected_fields=self._query_job.query_results().schema)
            self._query_data = iter(rows_iter)
def _try_fetch ( self , size = None ) : if self . _query_job is None : raise exceptions . InterfaceError ( 'No query results: execute() must be called before fetch.' ) is_dml = ( self . _query_job . statement_type and self . _query_job . statement_type . upper ( ) != 'SELECT' ) if is_dml : self . _query_data = iter ( [ ] ) return if self . _query_data is None : client = self . connection . _client rows_iter = client . list_rows ( self . _query_job . destination , selected_fields = self . _query_job . query_results ( ) . schema ) self . _query_data = iter ( rows_iter )
Try to start fetching data, if not yet started.
Try to start fetching data if not yet started .
"""Try to start fetching data, if not yet started.

        Mutates self to indicate that iteration has started.
        """ # TODO(tswast): pass in page size to list_rows based on arraysize
self
size