(airflow) branch main updated: Replace `converted_rows[0].keys()` with `fields` (#50442)

[jscheffl]

This is an automated email from the ASF dual-hosted git repository.

jscheffl 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 da3a8c9b08f Replace `converted_rows[0].keys()` with `fields` (#50442)
da3a8c9b08f is described below

commit da3a8c9b08f5febc33e36fe37f229d76bcbe9415
Author: Aaron Chen <nail...@gmail.com>
AuthorDate: Sun May 11 06:00:31 2025 -0700

    Replace `converted_rows[0].keys()` with `fields` (#50442)
---
 .../src/airflow/providers/google/cloud/transfers/facebook_ads_to_gcs.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 938c257448b..ea436670766 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 @@ class FacebookAdsReportToGcsOperator(BaseOperator):
 
     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()