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