We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1ae7160 commit 78fc51dCopy full SHA for 78fc51d
1 file changed
sdks/python/apache_beam/typehints/typecheck_test.py
@@ -315,8 +315,7 @@ def test_visitor_applies_single_wrapper_layer(self):
315
# A single RuntimeTypeCheckWrapperDoFn should wrap the user's DoFn
316
# directly, with no intermediate wrapper layers.
317
p = beam.Pipeline(options=PipelineOptions(runtime_type_check=True))
318
- _ = (
319
- p | beam.Create([1, 2]) | 'TypedStep' >> beam.ParDo(_AddOneDoFn()))
+ _ = (p | beam.Create([1, 2]) | 'TypedStep' >> beam.ParDo(_AddOneDoFn()))
320
p.visit(typecheck.TypeCheckVisitor())
321
322
wrapped_dofns = []
@@ -350,4 +349,4 @@ def test_wrapper_preserves_results(self):
350
349
351
352
if __name__ == '__main__':
353
- unittest.main()
+ unittest.main()
0 commit comments