We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 396b3ab commit 4433ce6Copy full SHA for 4433ce6
sdks/python/apache_beam/io/gcp/pubsub.py
@@ -608,13 +608,14 @@ def __init__(self, transform):
608
if pipeline_options:
609
try:
610
standard_options = pipeline_options.view_as(StandardOptions)
611
- streaming_info = f'streaming={standard_options.streaming}'
612
- except:
+ streaming_info = 'streaming=%s' % standard_options.streaming
+ except Exception:
613
streaming_info = 'streaming=unknown'
614
615
logging.warning(
616
- f'PubSub unsupported feature check: '
617
- f'runner={runner_info}, {streaming_info}')
+ 'PubSub unsupported feature check: runner=%s, %s',
+ runner_info,
618
+ streaming_info)
619
620
if transform.id_label:
621
raise NotImplementedError(
0 commit comments