observable process manager spike
observable processing dsl + example tests