diff --git a/lib/lambdakiq/adapter.rb b/lib/lambdakiq/adapter.rb index 6f20616..415ea9d 100644 --- a/lib/lambdakiq/adapter.rb +++ b/lib/lambdakiq/adapter.rb @@ -10,6 +10,10 @@ def enqueue_at(job, timestamp) enqueue job, delay_seconds: delay_seconds(timestamp) end + def enqueue_after_transaction_commit? + true + end + private def delay_seconds(timestamp)