BigQueryInsertJobOperator doesn't include BigQuery region/location in deferrable mode

[manhld0206]

Apache Airflow version

Other Airflow 2 version (please specify below)

What happened

I tested BigQueryInsertJobOperator with deferrable mode enabled.
I used Google Cloud Composer 2.4.0 with airflow version 2.4.3
The BigQuery's region is asia-northeast1 region. The operator ran fine before but I got Job not found error after enabling deferrable mode. At first I thought it was because I didn't specify location parameter in BigQueryInsertJobOperator. However, even after changing it, I still got the Job not found error.

After taking a quick look at the source code, I guess maybe the cause is BigQuery Trigger doesn't include location in it's parameters.
The code

airflow/airflow/providers/google/cloud/triggers/bigquery.py

Line 90 in 0e157b3

job_status = await hook.get_job_status(job_id=self.job_id, project_id=self.project_id)

BigQuery get job API doc

What you think should happen instead

No response

How to reproduce

Execute BigQueryInsertJobOperator using asia-northeast1 BigQuery region

Operating System

It's not OS. I used Google Cloud Composer 2.4.0 with airflow version 2.4.3

Versions of Apache Airflow Providers

No response

Deployment

Google Cloud Composer

Deployment details

No response

Anything else

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[boring-cyborg]

Thanks for opening your first issue here! Be sure to follow the issue template! If you are willing to raise PR to address this issue please do so, no need to wait for approval.

[eladkal]

feel free to open PR to address the issue

[kadai0308]

Hi, after go through the code, i think i can fix this issue by pass the location as param at here.
Can you please assgin the issue to me?

[manhld0206]

I would like to add another note.
Some other BigQuery operators (For example GCSToBigQueryOperator) might have the same problem as well. Because if the operator uses BigQueryInsertJobTrigger, it won't pass the location param.

[manhld0206]

@kadai0308
Is it ok for me to take this issue. It will be my first commit ever to airflow but I would like to challenge it!