Skip to content

Commit c82b3b9

Browse files
authored
GCSFileTransformOperator: New templated fields source_object, destination_object (#23328)
* `GCSFileTransformOperator`: New templated fields `source_object`, `destination_object` * Add `source_object`, `destination_object` as templated fields * fix docstring closes: #23327
1 parent 505af06 commit c82b3b9

File tree

1 file changed

+8
-2
lines changed
  • airflow/providers/google/cloud/operators

1 file changed

+8
-2
lines changed

airflow/providers/google/cloud/operators/gcs.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -536,8 +536,12 @@ class GCSFileTransformOperator(BaseOperator):
536536
data from source, transform it and write the output to the local
537537
destination file.
538538
539-
:param source_bucket: The key to be retrieved from GCS. (templated)
540-
:param destination_bucket: The key to be written from GCS. (templated)
539+
:param source_bucket: The bucket to locate the source_object. (templated)
540+
:param source_object: The key to be retrieved from GCS. (templated)
541+
:param destination_bucket: The bucket to upload the key after transformation.
542+
If not provided, source_bucket will be used. (templated)
543+
:param destination_object: The key to be written in GCS.
544+
If not provided, source_object will be used. (templated)
541545
:param transform_script: location of the executable transformation script or list of arguments
542546
passed to subprocess ex. `['python', 'script.py', 10]`. (templated)
543547
:param gcp_conn_id: The connection ID to use connecting to Google Cloud.
@@ -553,7 +557,9 @@ class GCSFileTransformOperator(BaseOperator):
553557

554558
template_fields: Sequence[str] = (
555559
'source_bucket',
560+
'source_object',
556561
'destination_bucket',
562+
'destination_object',
557563
'transform_script',
558564
'impersonation_chain',
559565
)

0 commit comments

Comments
 (0)