We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ebf3642 commit 012d4a6Copy full SHA for 012d4a6
1 file changed
features/step_definitions/worker_steps.rb
@@ -10,10 +10,13 @@ def drain_async_jobs
10
active_job.jobs.each do |job|
11
case job['wrapped']
12
when AsyncCreatable::CreateAsyncJob.name, AsyncUpdatable::UpdateAsyncJob.name,
13
- AsyncTouchable::TouchAsyncJob.name, AsyncDestroyable::DestroyAsyncJob.name
+ AsyncTouchable::TouchAsyncJob.name, AsyncDestroyable::DestroyAsyncJob.name,
14
+ ActiveRecord::DestroyAssociationAsyncJob.name
15
active_job.process_job(job)
16
end
17
18
+
19
+ YankArtifactWorker.drain
20
21
22
Then /^sidekiq should (?:have|process) (\d+) "([^\"]*)" jobs?(?: queued in ([.\d]+ \w+))?$/ do |expected_count, worker_name, queued_at|
0 commit comments