diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py index d6654141532a2..e8ba86d7172e9 100644 --- a/airflow/providers/google/cloud/operators/bigquery.py +++ b/airflow/providers/google/cloud/operators/bigquery.py @@ -186,6 +186,8 @@ def get_openlineage_facets_on_complete(self, task_instance): job_facets = {} if hasattr(self, "sql"): job_facets["sql"] = SqlJobFacet(query=normalize_sql(self.sql)) + if hasattr(self, "_executed_sql"): + job_facets["sql"] = SqlJobFacet(query=normalize_sql(self._executed_sql)) return OperatorLineage( inputs=list(inputs.values()), @@ -2738,7 +2740,7 @@ def __init__( self.poll_interval = poll_interval @property - def sql(self) -> str | None: + def _executed_sql(self) -> str | None: try: return self.configuration["query"]["query"] except KeyError: