google/cloud/bigquery/job.py
def done(self, retry=DEFAULT_RETRY):
        """Refresh the job and checks if it is complete.

        :rtype: bool
        :returns: True if the job is complete, False otherwise.
        """
        # Since the API to getQueryResults can hang up to the timeout value
        # (default of 10 seconds), set the timeout parameter to ensure that
        # the timeout from the futures API is respected. See:
        # https://github.com/GoogleCloudPlatform/google-cloud-python/issues/4135
        timeout_ms = None
        if self._done_timeout is not None:
            # Subtract a buffer for context switching, network latency, etc.
            timeout = self._done_timeout - _TIMEOUT_BUFFER_SECS
            timeout = max(min(timeout, 10), 0)
            self._done_timeout -= timeout
            self._done_timeout = max(0, self._done_timeout)
            timeout_ms = int(timeout * 1000)

        # Do not refresh is the state is already done, as the job will not
        # change once complete.
        if self.state != _DONE_STATE:
            self._query_results = self._client._get_query_results(
                self.job_id, retry,
                project=self.project, timeout_ms=timeout_ms)

            # Only reload the job once we know the query is complete.
            # This will ensure that fields such as the destination table are
            # correctly populated.
            if self._query_results.complete:
                self.reload(retry=retry)

        return self.state == _DONE_STATE
Refresh the job and checks if it is complete.

        :rtype: bool
        :returns: True if the job is complete, False otherwise.
        
Refresh the job and checks if it is complete.
Refresh the job and checks if it is complete .
def done(self, retry=DEFAULT_RETRY):
        timeout_ms = None
        if self._done_timeout is not None:
            timeout = self._done_timeout - _TIMEOUT_BUFFER_SECS
            timeout = max(min(timeout, 10), 0)
            self._done_timeout -= timeout
            self._done_timeout = max(0, self._done_timeout)
            timeout_ms = int(timeout * 1000)
        if self.state != _DONE_STATE:
            self._query_results = self._client._get_query_results(
                self.job_id, retry,
                project=self.project, timeout_ms=timeout_ms)
            if self._query_results.complete:
                self.reload(retry=retry)
        return self.state == _DONE_STATE
def done ( self , retry = DEFAULT_RETRY ) : timeout_ms = None if self . _done_timeout is not None : timeout = self . _done_timeout - _TIMEOUT_BUFFER_SECS timeout = max ( min ( timeout , 10 ) , 0 ) self . _done_timeout -= timeout self . _done_timeout = max ( 0 , self . _done_timeout ) timeout_ms = int ( timeout * 1000 ) if self . state != _DONE_STATE : self . _query_results = self . _client . _get_query_results ( self . job_id , retry , project = self . project , timeout_ms = timeout_ms ) if self . _query_results . complete : self . reload ( retry = retry ) return self . state == _DONE_STATE
Refresh the job and checks if it is complete.
Refresh the job and checks if it is complete .
"""Refresh the job and checks if it is complete.

        :rtype: bool
        :returns: True if the job is complete, False otherwise.
        """ # Since the API to getQueryResults can hang up to the timeout value # (default of 10 seconds), set the timeout parameter to ensure that # the timeout from the futures API is respected. See: # https://github.com/GoogleCloudPlatform/google-cloud-python/issues/4135 # Subtract a buffer for context switching, network latency, etc. # Do not refresh is the state is already done, as the job will not # change once complete. # Only reload the job once we know the query is complete. # This will ensure that fields such as the destination table are # correctly populated.
True if the job is complete, False otherwise.
True if the job is complete False otherwise .
bool
self
retry