Class: Ci::RegisterJobService
- Inherits:
-
Object
- Object
- Ci::RegisterJobService
- Includes:
- Gitlab::Ci::Artifacts::Logger
- Defined in:
- app/services/ci/register_job_service.rb
Overview
This class responsible for assigning proper pending build to runner on runner API request
Defined Under Namespace
Classes: Result
Constant Summary collapse
- TEMPORARY_LOCK_TIMEOUT =
3.seconds
- MAX_QUEUE_DEPTH =
The queue depth limit number has been determined by observing 95 percentile of effective queue depth on gitlab.com. This is only likely to affect 5% of the worst case scenarios.
45
Instance Attribute Summary collapse
-
#metrics ⇒ Object
readonly
Returns the value of attribute metrics.
-
#runner ⇒ Object
readonly
Returns the value of attribute runner.
-
#runner_manager ⇒ Object
readonly
Returns the value of attribute runner_manager.
Instance Method Summary collapse
- #execute(params = {}) ⇒ Object
-
#initialize(runner, runner_manager) ⇒ RegisterJobService
constructor
A new instance of RegisterJobService.
Methods included from Gitlab::Ci::Artifacts::Logger
#log_artifacts_context, #log_artifacts_filesize, #log_build_dependencies, log_created, log_deleted
Constructor Details
#initialize(runner, runner_manager) ⇒ RegisterJobService
Returns a new instance of RegisterJobService.
21 22 23 24 25 |
# File 'app/services/ci/register_job_service.rb', line 21 def initialize(runner, runner_manager) @runner = runner @runner_manager = runner_manager @metrics = ::Gitlab::Ci::Queue::Metrics.new(runner) end |
Instance Attribute Details
#metrics ⇒ Object (readonly)
Returns the value of attribute metrics.
9 10 11 |
# File 'app/services/ci/register_job_service.rb', line 9 def metrics @metrics end |
#runner ⇒ Object (readonly)
Returns the value of attribute runner.
9 10 11 |
# File 'app/services/ci/register_job_service.rb', line 9 def runner @runner end |
#runner_manager ⇒ Object (readonly)
Returns the value of attribute runner_manager.
9 10 11 |
# File 'app/services/ci/register_job_service.rb', line 9 def runner_manager @runner_manager end |
Instance Method Details
#execute(params = {}) ⇒ Object
27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 |
# File 'app/services/ci/register_job_service.rb', line 27 def execute(params = {}) replica_caught_up = ::Ci::Runner.sticking.find_caught_up_replica(:runner, runner.id, use_primary_on_failure: false) @metrics.increment_queue_operation(:queue_attempt) result = @metrics.observe_queue_time(:process, @runner.runner_type) do process_queue(params) end # Since we execute this query against replica it might lead to false-positive # We might receive the positive response: "hi, we don't have any more builds for you". # This might not be true. If our DB replica is not up-to date with when runner event was generated # we might still have some CI builds to be picked. Instead we should say to runner: # "Hi, we don't have any more builds now, but not everything is right anyway, so try again". # Runner will retry, but again, against replica, and again will check if replication lag did catch-up. if !replica_caught_up && !result.build metrics.increment_queue_operation(:queue_replication_lag) ::Ci::RegisterJobService::Result.new(nil, nil, nil, false) # rubocop:disable Cop/AvoidReturnFromBlocks else result end end |