Usage:
sbt "runMain com.spotify.scio.examples.extra.WordCountOrchestration
--project=[PROJECT] --runner=DataflowRunner --region=[REGION NAME]
--output=gs://[BUCKET]/[PATH]/wordcount"
Submit count job 1
Submit count job 2
extract Tap[T]
s from two Future[Tap[T]]
s
Block process and wait for last future
Split out transform for unit testing
Split out transform for unit testing
Use Futures and Taps to orchestrate multiple jobs with dependencies