Top-level exception handling for all threads
Added Task.is_run_by_worker
Changed most log warnings to info
Include specific queues when sending control msgs
Added opens for pausing/resuming.
Changed setup / ensure_index to not happen every time