Skip to content

Commit 7916452

Browse files
authored
Fix internal test configuration for Dataflow client (#38792)
1 parent 13a4635 commit 7916452

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • sdks/python/apache_beam/runners/dataflow/internal

sdks/python/apache_beam/runners/dataflow/internal/apiclient.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -520,7 +520,7 @@ def __init__(self, options, root_staging_location=None):
520520
transport = None
521521
if self.google_cloud_options.dataflow_endpoint:
522522
endpoint = self.google_cloud_options.dataflow_endpoint
523-
if 'localhost' in endpoint:
523+
if 'localhost' in endpoint or 'sandbox' in endpoint:
524524
transport = 'rest'
525525
else:
526526
endpoint = re.sub('^https?://', '', endpoint)

0 commit comments

Comments
 (0)