File tree 1 file changed +9
-2
lines changed
1 file changed +9
-2
lines changed Original file line number Diff line number Diff line change @@ -39,7 +39,10 @@ def release_all
39
39
def fail_all_with ( error )
40
40
SolidQueue . instrument ( :fail_many_claimed ) do |payload |
41
41
includes ( :job ) . tap do |executions |
42
- executions . each { |execution | execution . failed_with ( error ) }
42
+ executions . each do |execution |
43
+ execution . failed_with ( error )
44
+ execution . unblock_next_job
45
+ end
43
46
44
47
payload [ :process_ids ] = executions . map ( &:process_id ) . uniq
45
48
payload [ :job_ids ] = executions . map ( &:job_id ) . uniq
@@ -67,7 +70,7 @@ def perform
67
70
raise result . error
68
71
end
69
72
ensure
70
- job . unblock_next_blocked_job
73
+ unblock_next_job
71
74
end
72
75
73
76
def release
@@ -90,6 +93,10 @@ def failed_with(error)
90
93
end
91
94
end
92
95
96
+ def unblock_next_job
97
+ job . unblock_next_blocked_job
98
+ end
99
+
93
100
private
94
101
def execute
95
102
ActiveJob ::Base . execute ( job . arguments . merge ( "provider_job_id" => job . id ) )
You can’t perform that action at this time.
0 commit comments