Check cache in Ci::Runner#online?

app/models/ci/runner.rb

@@ -88,7 +88,10 @@ module Ci
     end
 
     def online?
-      contacted_at && contacted_at > self.class.contact_time_deadline
+      Gitlab::Redis::SharedState.with do |redis|
+        last_seen = redis.get("#{self.runner_info_key}:contacted_at") || contacted_at
+        last_seen && last_seen > self.class.contact_time_deadline
+      end
     end
 
     def status
@@ -152,6 +155,10 @@ module Ci
       ensure_runner_queue_value == value if value.present?
     end
 
+    def runner_info_key
+      "runner:info:#{self.id}"
+    end
+
     private
 
     def cleanup_runner_queue

spec/models/ci/runner_spec.rb

@@ -95,6 +95,11 @@ describe Ci::Runner do
 
     subject { runner.online? }
 
+    context 'no cache value' do
+      before do
+        stub_redis("#{runner.runner_info_key}:contacted_at", nil)
+      end
+
       context 'never contacted' do
         before do
           runner.contacted_at = nil
@@ -120,6 +125,31 @@ describe Ci::Runner do
       end
     end
 
+    context 'with cache value' do
+      context 'contacted long time ago time' do
+        before do
+          stub_redis("#{runner.runner_info_key}:contacted_at", 1.year.ago.to_s)
+        end
+
+        it { is_expected.to be_falsey }
+      end
+
+      context 'contacted 1s ago' do
+        before do
+          stub_redis("#{runner.runner_info_key}:contacted_at", 1.second.ago.to_s)
+        end
+
+        it { is_expected.to be_truthy }
+      end
+    end
+
+    def stub_redis(key, value)
+      redis = double
+      allow(Gitlab::Redis::SharedState).to receive(:with).and_yield(redis)
+      allow(redis).to receive(:get).with(key).and_return(value)
+    end
+  end
+
   describe '#can_pick?' do
     let(:pipeline) { create(:ci_pipeline) }
     let(:build) { create(:ci_build, pipeline: pipeline) }