shunping commented on code in PR #37674:
URL: https://github.com/apache/beam/pull/37674#discussion_r2836215482
##########
sdks/python/apache_beam/io/gcp/gcsfilesystem.py:
##########
@@ -139,7 +147,11 @@ def _list(self, dir_or_prefix):
raise BeamIOError("List operation failed", {dir_or_prefix: e})
def _gcsIO(self):
- return gcsio.GcsIO(pipeline_options=self._pipeline_options)
+ if gcsio is None:
+ from apache_beam.io.gcp import gcsio as _gcsio # pylint:
disable=g-import-not-at-top
Review Comment:
Could you explain Why we need to try importing gcsio again if the import at
the beginning of the module fails?
--
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]
