From 4301bc81a47933c8962af35bf16f3650d6388a32 Mon Sep 17 00:00:00 2001 From: jrmccluskey Date: Wed, 3 Jun 2026 13:26:49 -0400 Subject: [PATCH] Fix internal test configuration for Dataflow client --- sdks/python/apache_beam/runners/dataflow/internal/apiclient.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py index 531c076ffdf0..fdf2e0ea03e3 100644 --- a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py +++ b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py @@ -520,7 +520,7 @@ def __init__(self, options, root_staging_location=None): transport = None if self.google_cloud_options.dataflow_endpoint: endpoint = self.google_cloud_options.dataflow_endpoint - if 'localhost' in endpoint: + if 'localhost' in endpoint or 'sandbox' in endpoint: transport = 'rest' else: endpoint = re.sub('^https?://', '', endpoint)