tree: abaab093938e894c512255c877731af11d1f4147
  1. clustering_pipeline/
  2. write_data_to_pubsub_pipeline/