uranusjr commented on a change in pull request #17446:
URL: https://github.com/apache/airflow/pull/17446#discussion_r686506159
##########
File path: airflow/providers/google/cloud/hooks/gcs.py
##########
@@ -1207,3 +1204,7 @@ def _parse_gcs_url(gsurl: str) -> Tuple[str, str]:
# Remove leading '/' but NOT trailing one
blob = parsed_url.path.lstrip('/')
return bucket, blob
+
+
+def _normalize_directory_path(source_object: Optional[str]) -> Optional[str]:
+ return source_object + "/" if source_object and not
source_object.endswith("/") else source_object
Review comment:
This function should be moved somewhere in the `utils` directory (and
named without the leading prefix)
--
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]
