We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5df737c commit 3eed153Copy full SHA for 3eed153
lib/async/job/backend/aggregate/server.rb
@@ -52,14 +52,14 @@ def run(task)
52
# We are creating a task:
53
@task = true
54
55
- parent.async(transient: true) do |task|
+ parent.async(transient: true, annotation: self.class.name) do |task|
56
@task = task
57
58
run(task)
59
ensure
60
# Ensure that all jobs are flushed before we exit:
61
- flush(@pending) if @pending.any?
62
flush(@processing) if @processing.any?
+ flush(@pending) if @pending.any?
63
@task = nil
64
end
65
0 commit comments