Class: Gitlab::GithubImport::Stage::ImportLfsObjectsWorker
- Inherits:
-
Object
- Object
- Gitlab::GithubImport::Stage::ImportLfsObjectsWorker
- Includes:
- ApplicationWorker, Queue, Gitlab::GithubImport::StageMethods
- Defined in:
- app/workers/gitlab/github_import/stage/import_lfs_objects_worker.rb
Overview
rubocop:disable Scalability/IdempotentWorker
Constant Summary
Constants included from ApplicationWorker
ApplicationWorker::LOGGING_EXTRA_KEY, ApplicationWorker::SAFE_PUSH_BULK_LIMIT
Constants included from Loggable
Constants included from WorkerAttributes
WorkerAttributes::DEFAULT_DATA_CONSISTENCY, WorkerAttributes::DEFAULT_DEFER_DELAY, WorkerAttributes::NAMESPACE_WEIGHTS, WorkerAttributes::VALID_DATA_CONSISTENCIES, WorkerAttributes::VALID_RESOURCE_BOUNDARIES, WorkerAttributes::VALID_URGENCIES
Instance Method Summary collapse
-
#import(project) ⇒ Object
project - An instance of Project.
- #perform(project_id) ⇒ Object
Methods included from Gitlab::GithubImport::StageMethods
#abort_on_failure, #find_project, #try_import
Methods included from Loggable
Methods included from SidekiqVersioning::Worker
Methods included from WorkerContext
Instance Method Details
#import(project) ⇒ Object
project - An instance of Project.
22 23 24 25 26 27 28 29 30 31 32 33 34 |
# File 'app/workers/gitlab/github_import/stage/import_lfs_objects_worker.rb', line 22 def import(project) info(project.id, message: "starting importer", importer: 'Importer::LfsObjectsImporter') waiter = Importer::LfsObjectsImporter .new(project, nil) .execute AdvanceStageWorker.perform_async( project.id, { waiter.key => waiter.jobs_remaining }, :finish ) end |
#perform(project_id) ⇒ Object
15 16 17 18 19 |
# File 'app/workers/gitlab/github_import/stage/import_lfs_objects_worker.rb', line 15 def perform(project_id) return unless (project = find_project(project_id)) import(project) end |