fix: Ensure DataExports::CombinePartsJob uniqueness (#2777)

This should fix a race condition when multiple data export parts are finished very close in time resulting into multiple CombinePartsJob queued, hence active storage fails because of duplicated key.
getlago · Nov 5, 2024 · 4617b49 · 4617b49
1 parent 2734962
commit 4617b49
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/app/jobs/data_exports/combine_parts_job.rb b/app/jobs/data_exports/combine_parts_job.rb
@@ -4,6 +4,8 @@ module DataExports
   class CombinePartsJob < ApplicationJob
     queue_as :default
 
+    unique :until_executed, on_conflict: :log
+
     def perform(data_export)
       CombinePartsService.call(data_export:).raise_if_error!
     end