pipeline:
  - type: chain
    transforms:
      - type: ReadFromCsv
        path: "gs://apache-beam-samples/nasa_jpl_asteroid/sample_1000.csv"
      - type: PyFilter
        fn: "lambda astroid: (astroid.diameter or 0) > 250"
      - type: PyMap
        fn: print