lib/acidic_job/mixin.rb in acidic_job-0.8.1 vs lib/acidic_job/mixin.rb in acidic_job-0.8.2

- old
+ new

@@ -75,12 +75,11 @@ def safely_finish_acidic_job FinishedPoint.new end def with_acidic_workflow(persisting: {}, &block) - raise UnknownJobAdapter unless (defined?(::AcidicJob::Base) && self.class < ::AcidicJob::Base) || - (defined?(::AcidicJob::ActiveKiq) && self.class < ::AcidicJob::ActiveKiq) + raise UnknownJobAdapter unless known_job_adapter? raise RedefiningWorkflow if defined? @workflow_builder @workflow_builder = WorkflowBuilder.new @@ -247,8 +246,16 @@ when :sqlite :read_uncommitted else :serializable end + end + + def known_job_adapter? + return true if defined?(::AcidicJob::Base) && self.class < ::AcidicJob::Base + return true if defined?(::AcidicJob::ActiveKiq) && self.class < ::AcidicJob::ActiveKiq + return true if defined?(::ActiveJob) && self.class < ::ActiveJob::Base + + false end end end