tree: fd6cc0f54238957015491581d2aa36a5c5fc4eff
  1. clustering_pipeline/
  2. write_data_to_pubsub_pipeline/