Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitlab-foss.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'app/workers/concerns/waitable_worker.rb')
-rw-r--r--app/workers/concerns/waitable_worker.rb25
1 files changed, 0 insertions, 25 deletions
diff --git a/app/workers/concerns/waitable_worker.rb b/app/workers/concerns/waitable_worker.rb
index 9300c2a5790..f23e3fb20c2 100644
--- a/app/workers/concerns/waitable_worker.rb
+++ b/app/workers/concerns/waitable_worker.rb
@@ -6,33 +6,8 @@ module WaitableWorker
class_methods do
# Schedules multiple jobs and waits for them to be completed.
def bulk_perform_and_wait(args_list)
- # Short-circuit: it's more efficient to do small numbers of jobs inline
- if args_list.size == 1 && !always_async_project_authorizations_refresh?
- return bulk_perform_inline(args_list)
- end
-
bulk_perform_async(args_list)
end
-
- # Performs multiple jobs directly. Failed jobs will be put into sidekiq so
- # they can benefit from retries
- def bulk_perform_inline(args_list)
- failed = []
-
- args_list.each do |args|
- worker = new
- Gitlab::AppJsonLogger.info(worker.structured_payload(message: 'running inline'))
- worker.perform(*args)
- rescue StandardError
- failed << args
- end
-
- bulk_perform_async(failed) if failed.present?
- end
-
- def always_async_project_authorizations_refresh?
- Feature.enabled?(:always_async_project_authorizations_refresh)
- end
end
def perform(*args)