* Refactored the way worker polling is scheduled and errors are handled. * Share the worker future as a Shared