diff --git a/airflow/providers/google/cloud/transfers/mssql_to_gcs.py b/airflow/providers/google/cloud/transfers/mssql_to_gcs.py index 113b0713d146d..3451de8e263b1 100644 --- a/airflow/providers/google/cloud/transfers/mssql_to_gcs.py +++ b/airflow/providers/google/cloud/transfers/mssql_to_gcs.py @@ -26,7 +26,7 @@ class MSSQLToGCSOperator(BaseSQLToGCSOperator): """Copy data from Microsoft SQL Server to Google Cloud Storage - in JSON or CSV format. + in JSON, CSV or Parquet format. :param mssql_conn_id: Reference to a specific MSSQL hook. diff --git a/airflow/providers/google/cloud/transfers/mysql_to_gcs.py b/airflow/providers/google/cloud/transfers/mysql_to_gcs.py index 2e72eaa774c38..4f05a6e51e64d 100644 --- a/airflow/providers/google/cloud/transfers/mysql_to_gcs.py +++ b/airflow/providers/google/cloud/transfers/mysql_to_gcs.py @@ -29,7 +29,7 @@ class MySQLToGCSOperator(BaseSQLToGCSOperator): - """Copy data from MySQL to Google Cloud Storage in JSON or CSV format. + """Copy data from MySQL to Google Cloud Storage in JSON, CSV or Parquet format. .. seealso:: For more information on how to use this operator, take a look at the guide: diff --git a/airflow/providers/google/cloud/transfers/oracle_to_gcs.py b/airflow/providers/google/cloud/transfers/oracle_to_gcs.py index d5fa696c50732..a261301df21ae 100644 --- a/airflow/providers/google/cloud/transfers/oracle_to_gcs.py +++ b/airflow/providers/google/cloud/transfers/oracle_to_gcs.py @@ -29,7 +29,7 @@ class OracleToGCSOperator(BaseSQLToGCSOperator): - """Copy data from Oracle to Google Cloud Storage in JSON or CSV format. + """Copy data from Oracle to Google Cloud Storage in JSON, CSV or Parquet format. .. seealso:: For more information on how to use this operator, take a look at the guide: diff --git a/airflow/providers/google/cloud/transfers/postgres_to_gcs.py b/airflow/providers/google/cloud/transfers/postgres_to_gcs.py index 97748003dbaee..e1f1eeca6ac0a 100644 --- a/airflow/providers/google/cloud/transfers/postgres_to_gcs.py +++ b/airflow/providers/google/cloud/transfers/postgres_to_gcs.py @@ -67,7 +67,7 @@ def description(self): class PostgresToGCSOperator(BaseSQLToGCSOperator): """ - Copy data from Postgres to Google Cloud Storage in JSON or CSV format. + Copy data from Postgres to Google Cloud Storage in JSON, CSV or Parquet format. :param postgres_conn_id: Reference to a specific Postgres hook. :param use_server_side_cursor: If server-side cursor should be used for querying postgres. diff --git a/airflow/providers/google/cloud/transfers/presto_to_gcs.py b/airflow/providers/google/cloud/transfers/presto_to_gcs.py index 1b2be5e091a19..5bd30688c70ce 100644 --- a/airflow/providers/google/cloud/transfers/presto_to_gcs.py +++ b/airflow/providers/google/cloud/transfers/presto_to_gcs.py @@ -141,7 +141,7 @@ def __iter__(self) -> "_PrestoToGCSPrestoCursorAdapter": class PrestoToGCSOperator(BaseSQLToGCSOperator): - """Copy data from PrestoDB to Google Cloud Storage in JSON or CSV format. + """Copy data from PrestoDB to Google Cloud Storage in JSON, CSV or Parquet format. :param presto_conn_id: Reference to a specific Presto hook. """ diff --git a/airflow/providers/google/cloud/transfers/sql_to_gcs.py b/airflow/providers/google/cloud/transfers/sql_to_gcs.py index bfee9dd1d2930..fda5f238d65d1 100644 --- a/airflow/providers/google/cloud/transfers/sql_to_gcs.py +++ b/airflow/providers/google/cloud/transfers/sql_to_gcs.py @@ -34,7 +34,7 @@ class BaseSQLToGCSOperator(BaseOperator): """ - Copy data from SQL to Google Cloud Storage in JSON or CSV format. + Copy data from SQL to Google Cloud Storage in JSON, CSV, or Parquet format. :param sql: The SQL to execute. :param bucket: The bucket to upload to. @@ -50,7 +50,7 @@ class BaseSQLToGCSOperator(BaseOperator): filename param docs above). This param allows developers to specify the file size of the splits. Check https://cloud.google.com/storage/quotas to see the maximum allowed file size for a single object. - :param export_format: Desired format of files to be exported. + :param export_format: Desired format of files to be exported. (json, csv or parquet) :param field_delimiter: The delimiter to be used for CSV files. :param null_marker: The null marker to be used for CSV files. :param gzip: Option to compress file for upload (does not apply to schemas). diff --git a/airflow/providers/google/cloud/transfers/trino_to_gcs.py b/airflow/providers/google/cloud/transfers/trino_to_gcs.py index 6d2e2e223b3dc..13b975374a27b 100644 --- a/airflow/providers/google/cloud/transfers/trino_to_gcs.py +++ b/airflow/providers/google/cloud/transfers/trino_to_gcs.py @@ -141,7 +141,7 @@ def __iter__(self) -> "_TrinoToGCSTrinoCursorAdapter": class TrinoToGCSOperator(BaseSQLToGCSOperator): - """Copy data from TrinoDB to Google Cloud Storage in JSON or CSV format. + """Copy data from TrinoDB to Google Cloud Storage in JSON, CSV or Parquet format. :param trino_conn_id: Reference to a specific Trino hook. """