Added schema declaration to the top of the workflow datastream