BjornPrime commented on code in PR #28079:
URL: https://github.com/apache/beam/pull/28079#discussion_r1336000865
##########
sdks/python/apache_beam/runners/dataflow/internal/apiclient.py:
##########
@@ -492,12 +491,19 @@ def __init__(self, options, root_staging_location=None):
self._root_staging_location = (
root_staging_location or self.google_cloud_options.staging_location)
- self.environment_version = _FNAPI_ENVIRONMENT_MAJOR_VERSION
+ from apache_beam.runners.dataflow.dataflow_runner import
_is_runner_v2_disabled
+ from google.cloud import storage
+ if _is_runner_v2_disabled(options):
Review Comment:
It does. Not sure how that happened. If we're no longer supporting the
legacy runner (as I seem to recall we are not), I'll make sure to change it.
--
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]
