improve error handling and fix swallowed processor exceptions
Pass worker context to processors so they can pause/resume workers.