This is an automated email from the ASF dual-hosted git repository.
potiuk 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 63f3712d2e Update gcs.py Create and List comment Examples (#35028)
63f3712d2e is described below
commit 63f3712d2e5874ced8b3bf3e79eeaf6eaf059df5
Author: Hyouka <[email protected]>
AuthorDate: Wed Oct 18 21:51:51 2023 +0200
Update gcs.py Create and List comment Examples (#35028)
Since the class is GCSListObjectsOperator, the task call should be
respectively as follows:
GCS_Files = GoogleCloudStorageListOperator
Similarly, for GCSCreateBucketOperator, the task call should be as follows:
CreateBucket = GCSCreateBucketOperator
---
airflow/providers/google/cloud/operators/gcs.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/providers/google/cloud/operators/gcs.py
b/airflow/providers/google/cloud/operators/gcs.py
index 811f589253..61bcd013c2 100644
--- a/airflow/providers/google/cloud/operators/gcs.py
+++ b/airflow/providers/google/cloud/operators/gcs.py
@@ -90,7 +90,7 @@ class GCSCreateBucketOperator(GoogleCloudBaseOperator):
.. code-block:: python
- CreateBucket = GoogleCloudStorageCreateBucketOperator(
+ CreateBucket = GCSCreateBucketOperator(
task_id="CreateNewBucket",
bucket_name="test-bucket",
storage_class="MULTI_REGIONAL",
@@ -187,7 +187,7 @@ class GCSListObjectsOperator(GoogleCloudBaseOperator):
The following Operator would list all the Avro files from
``sales/sales-2017``
folder in ``data`` bucket. ::
- GCS_Files = GoogleCloudStorageListOperator(
+ GCS_Files = GCSListOperator(
task_id='GCS_Files',
bucket='data',
prefix='sales/sales-2017/',
