lib/rocket_job/job.rb in rocketjob-0.9.1 vs lib/rocket_job/job.rb in rocketjob-1.0.0

@@ -213,9 +213,14 @@
     # Resume all paused jobs
     def self.resume_all
       where(state: 'paused').each { |job| job.resume! }
     end
 
+    # Returns the number of required arguments for this job
+    def self.argument_count(method=:perform)
+      instance_method(method).arity
+    end
+
     # Returns [true|false] whether to collect the results from running this batch
     def collect_output?
       collect_output == true
     end