airflow_blog_post_sample_1.py

def execute(self, context: Any):
        hook = BigQueryHook(
            gcp_conn_id=self.gcp_conn_id,
            delegate_to=self.delegate_to,
            impersonation_chain=self.impersonation_chain,
        )
        self.hook = hook

        job_id = self._job_id(context)

# ... code suppresed for readability

        self.job_id = job.job_id
        return job.job_id