Data Integrity in Asynchronous Pipelines

Validate message schemas at the input and output stages of every worker.