diff options
Diffstat (limited to 'lib/gitlab/phabricator_import/worker_state.rb')
| -rw-r--r-- | lib/gitlab/phabricator_import/worker_state.rb | 47 |
1 files changed, 0 insertions, 47 deletions
diff --git a/lib/gitlab/phabricator_import/worker_state.rb b/lib/gitlab/phabricator_import/worker_state.rb deleted file mode 100644 index ffa2d3d7a43..00000000000 --- a/lib/gitlab/phabricator_import/worker_state.rb +++ /dev/null @@ -1,47 +0,0 @@ -# frozen_string_literal: true -module Gitlab - module PhabricatorImport - class WorkerState - def initialize(project_id) - @project_id = project_id - end - - def add_job - redis.with do |r| - r.pipelined do |pipe| - pipe.incr(all_jobs_key) - pipe.expire(all_jobs_key, timeout) - end - end - end - - def remove_job - redis.with do |r| - r.decr(all_jobs_key) - end - end - - def running_count - redis.with { |r| r.get(all_jobs_key) }.to_i - end - - private - - attr_reader :project_id - - def redis - Gitlab::Redis::SharedState - end - - def all_jobs_key - @all_jobs_key ||= "phabricator-import/jobs/project-#{project_id}/job-count" - end - - def timeout - # Make sure we get rid of all the information after a job is marked - # as failed/succeeded - Gitlab::Import::StuckImportJob::IMPORT_JOBS_EXPIRATION - end - end - end -end |