def _extract()

in pipelines/ml_ai_python/ml_ai_pipeline/pipeline.py [0:0]

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

def _extract(p: Pipeline, subscription: str) -> PCollection[str]:
  msgs: PCollection[bytes] = p | "Read subscription" >> beam.io.ReadFromPubSub(
      subscription=subscription)
  return msgs | "Parse" >> beam.Map(lambda x: x.decode("utf-8"))