Rescues around the execute.

This prevents the executor from crashing entirely when mosquito itself
encounters an error during the execution setup/teardown. The most common
case for this is when mosquito is running against a redis that has jobs
it's unaware of, and it fails to deserialize the Job.

Author: robacarp

src/mosquito/runners/executor.cr

@@ -120,7 +120,18 @@ module Mosquito::Runners
       self.state = State::Working
       @work_unit = dequeue
       log.trace { "Dequeued #{job_run} from #{queue.name}" }
-      execute
+
+      begin
+        execute
+      rescue e
+        log.error { "Crashed executing #{job_run}: #{e.inspect}" }
+        begin
+          job_run.retry_or_banish queue
+        rescue
+          queue.banish job_run
+        end
+      end
+
       log.trace { "Finished #{job_run} from #{queue.name}" }
 
       if @decommissioned