diff --git a/providers/google/src/airflow/providers/google/cloud/transfers/facebook_ads_to_gcs.py b/providers/google/src/airflow/providers/google/cloud/transfers/facebook_ads_to_gcs.py index 938c257448bb8..ea43667076651 100644 --- a/providers/google/src/airflow/providers/google/cloud/transfers/facebook_ads_to_gcs.py +++ b/providers/google/src/airflow/providers/google/cloud/transfers/facebook_ads_to_gcs.py @@ -208,7 +208,7 @@ def _decide_and_flush(self, converted_rows_with_action: dict[FlushAction, list]) def _flush_rows(self, converted_rows: list[Any] | None, object_name: str): if converted_rows: - headers = converted_rows[0].keys() + headers = self.fields with tempfile.NamedTemporaryFile("w", suffix=".csv") as csvfile: writer = csv.DictWriter(csvfile, fieldnames=headers) writer.writeheader()