don't crash if there's an exception while enqueueing a job

lib/resque/scheduler.rb

@@ -103,14 +103,18 @@ def enqueue_delayed_items_for_timestamp(timestamp)
         begin
           handle_shutdown do
             if item = Resque.next_item_for_timestamp(timestamp)
-              log "queuing #{item['class']} [delayed]"
-              queue = item['queue'] || Resque.queue_from_class(constantize(item['class']))
-              # Support custom job classes like job with status
-              if (job_klass = item['custom_job_class']) && (job_klass != 'Resque::Job')
-                # custom job classes not supporting the same API calls must implement the #schedule method
-                constantize(job_klass).scheduled(queue, item['class'], *item['args'])
-              else
-                Resque::Job.create(queue, item['class'], *item['args'])
+              begin
+                log "queuing #{item['class']} [delayed]"
+                queue = item['queue'] || Resque.queue_from_class(constantize(item['class']))
+                # Support custom job classes like job with status
+                if (job_klass = item['custom_job_class']) && (job_klass != 'Resque::Job')
+                  # custom job classes not supporting the same API calls must implement the #schedule method
+                  constantize(job_klass).scheduled(queue, item['class'], *item['args'])
+                else
+                  Resque::Job.create(queue, item['class'], *item['args'])
+                end
+              rescue
+                log! "Failed to enqueue #{klass_name}:\n #{$!}"
               end
             end
           end
@@ -137,6 +141,8 @@ def enqueue_from_config(config)
         else
           Resque::Job.create(queue, klass_name, *params)
         end        
+      rescue
+        log! "Failed to enqueue #{klass_name}:\n #{$!}"
       end
 
       def rufus_scheduler

test/scheduler_test.rb

@@ -20,6 +20,11 @@ def test_enqueue_from_config_with_every_syntax
     Resque::Scheduler.enqueue_from_config('every' => '1m', 'class' => 'JamesJob', 'args' => '/tmp', 'queue' => 'james_queue')
   end
 
+  def test_enqueue_from_config_doesnt_crash_on_exception_when_enqueueing
+    Resque::Job.stubs(:create).raises(Resque::NoQueueError, 'test exception').with(:ivar, 'SomeIvarJob', '/tmp')
+    Resque::Scheduler.enqueue_from_config('cron' => "* * * * *", 'class' => 'SomeIvarJob', 'args' => "/tmp")
+  end
+
   def test_enqueue_from_config_puts_stuff_in_the_resque_queue
     Resque::Job.stubs(:create).once.returns(true).with(:ivar, 'SomeIvarJob', '/tmp')
     Resque::Scheduler.enqueue_from_config('cron' => "* * * * *", 'class' => 'SomeIvarJob', 'args' => "/tmp")