From d169006a43f5be23738321cb26ecce97f8df8696 Mon Sep 17 00:00:00 2001 From: Yi Hu Date: Tue, 29 Oct 2024 16:01:02 -0400 Subject: [PATCH] Fix indent --- sdks/python/apache_beam/io/gcp/bigquery_tools.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/sdks/python/apache_beam/io/gcp/bigquery_tools.py b/sdks/python/apache_beam/io/gcp/bigquery_tools.py index c0ff29f3afe3..b31f6449fe90 100644 --- a/sdks/python/apache_beam/io/gcp/bigquery_tools.py +++ b/sdks/python/apache_beam/io/gcp/bigquery_tools.py @@ -564,13 +564,13 @@ def _parse_location_from_exc(content, job_id): """Parse job location from Exception content.""" if isinstance(content, bytes): content = content.decode('ascii', 'replace') - # search for "Already Exists: Job :." - m = re.search(r"Already Exists: Job \S+\:(\S+)\." + job_id, content) - if not m: - _LOGGER.warning( - "Not able to parse BigQuery load job location for {}", job_id) - return None - return m.group(1) + # search for "Already Exists: Job :." + m = re.search(r"Already Exists: Job \S+\:(\S+)\." + job_id, content) + if not m: + _LOGGER.warning( + "Not able to parse BigQuery load job location for %s", job_id) + return None + return m.group(1) def _start_job( self,