Cleaned up interaction between StreamingHandler, Job and TaskRunner using async/await.