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