hankehly commented on code in PR #32760:
URL: https://github.com/apache/airflow/pull/32760#discussion_r1271258115
##########
airflow/providers/google/cloud/hooks/gcs.py:
##########
@@ -506,7 +529,7 @@ def _call_with_retry(f: Callable[[], None]) -> None:
continue
client = self.get_conn()
- bucket = client.bucket(bucket_name)
+ bucket = client.bucket(bucket_name, user_project=user_project)
Review Comment:
You can add support for "requester pays" buckets by specifying
`user_project` when creating a bucket object. All updates in this PR are
basically to pass `user_project` from the operator level to this bucket object
factory method.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
