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)