diff --git a/airflow/providers/google/cloud/transfers/postgres_to_gcs.py b/airflow/providers/google/cloud/transfers/postgres_to_gcs.py index d7c777757c33c..c233b5c4c9758 100644 --- a/airflow/providers/google/cloud/transfers/postgres_to_gcs.py +++ b/airflow/providers/google/cloud/transfers/postgres_to_gcs.py @@ -59,7 +59,8 @@ def description(self): """Fetch first row to initialize cursor description when using server side cursor.""" if not self.initialized: element = self.cursor.fetchone() - self.rows.append(element) + if element is not None: + self.rows.append(element) self.initialized = True return self.cursor.description