

def _insert_job(self, body_object):
    ' Submit a job to BigQuery\n\n            Direct proxy to the insert() method of the offical BigQuery\n            python client.\n\n            Able to submit load, link, query, copy, or extract jobs.\n\n            For more details, see:\n            https://google-api-client-libraries.appspot.com/documentation/bigquery/v2/python/latest/bigquery_v2.jobs.html#insert\n\n        Parameters\n        ----------\n        body_object : body object passed to bigquery.jobs().insert()\n\n        Returns\n        -------\n        response of the bigquery.jobs().insert().execute() call\n\n        Raises\n        ------\n        BigQueryTimeoutException on timeout\n        '
    logger.debug(('Submitting job: %s' % body_object))
    job_collection = self.bigquery.jobs()
    return job_collection.insert(projectId=self.project_id, body=body_object).execute()

dataset/ETHPy150Open tylertreat/BigQuery-Python/bigquery/client.py BigQueryClient._insert_job/original