def run()

in my_app/app.py [0:0]

• 4 lines of code
• 1 McCabe index (conditional complexity)

def run(
    input_text: str,
    beam_options: Optional[PipelineOptions] = None,
    test: Callable[[beam.PCollection], None] = lambda _: None,