Dataflow job reading tracked events from PubSub, validating and enriching them and writing them back to PubSub - View it on GitHub