This is an automated email from the ASF dual-hosted git repository.
shahar1 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new eb2e644bec3 Remove unused Dataproc job template helper (#75790)
eb2e644bec3 is described below
commit eb2e644bec3632f146d52776317c42e8cd2152e6
Author: Hussein Awala <[email protected]>
AuthorDate: Tue Oct 27 21:56:51 2026 +0100
Remove unused Dataproc job template helper (#75790)
The operator execute method builds its job template directly, and the
private wrapper has no callers.
---
generated/known_airflow_exceptions.txt | 2 +-
.../google/src/airflow/providers/google/cloud/operators/dataproc.py | 6 ------
2 files changed, 1 insertion(+), 7 deletions(-)
diff --git a/generated/known_airflow_exceptions.txt
b/generated/known_airflow_exceptions.txt
index 41bafef7fc3..c0c0e91a5dc 100644
--- a/generated/known_airflow_exceptions.txt
+++ b/generated/known_airflow_exceptions.txt
@@ -251,7 +251,7 @@
providers/google/src/airflow/providers/google/cloud/operators/compute.py::19
providers/google/src/airflow/providers/google/cloud/operators/dataflow.py::16
providers/google/src/airflow/providers/google/cloud/operators/datafusion.py::2
providers/google/src/airflow/providers/google/cloud/operators/dataplex.py::54
-providers/google/src/airflow/providers/google/cloud/operators/dataproc.py::32
+providers/google/src/airflow/providers/google/cloud/operators/dataproc.py::31
providers/google/src/airflow/providers/google/cloud/operators/dataproc_metastore.py::2
providers/google/src/airflow/providers/google/cloud/operators/datastore.py::2
providers/google/src/airflow/providers/google/cloud/operators/functions.py::6
diff --git
a/providers/google/src/airflow/providers/google/cloud/operators/dataproc.py
b/providers/google/src/airflow/providers/google/cloud/operators/dataproc.py
index 9d004d8b780..88059d97f45 100644
--- a/providers/google/src/airflow/providers/google/cloud/operators/dataproc.py
+++ b/providers/google/src/airflow/providers/google/cloud/operators/dataproc.py
@@ -1434,12 +1434,6 @@ class DataprocJobBaseOperator(GoogleCloudBaseOperator):
self.job_template = job_template
return job_template
- def _generate_job_template(self) -> str:
- if self.job_template:
- job = self.job_template.build()
- return job["job"]
- raise AirflowException("Create a job template before")
-
def execute(self, context: Context):
if self.job_template:
self.job = self.job_template.build()
