lib/good_job/lockable.rb in good_job-2.7.0 vs lib/good_job/lockable.rb in good_job-2.7.1
- old
+ new
@@ -22,11 +22,11 @@
# database session.
RecordAlreadyAdvisoryLockedError = Class.new(StandardError)
included do
# Default column to be used when creating Advisory Locks
- class_attribute :advisory_lockable_column, instance_accessor: false, default: Concurrent::Delay.new { primary_key }
+ class_attribute :advisory_lockable_column, instance_accessor: false, default: nil
# Default Postgres function to be used for Advisory Locks
class_attribute :advisory_lockable_function, default: "pg_try_advisory_lock"
# Attempt to acquire an advisory lock on the selected records and
@@ -159,13 +159,11 @@
end
end
end
end
- # Allow advisory_lockable_column to be a `Concurrent::Delay`
def _advisory_lockable_column
- column = advisory_lockable_column
- column.respond_to?(:value) ? column.value : column
+ advisory_lockable_column || primary_key
end
def supports_cte_materialization_specifiers?
return @_supports_cte_materialization_specifiers if defined?(@_supports_cte_materialization_specifiers)