Convert Geo::Scheduler::SchedulerWorker to use Gitlab::Geo::LogHelpers

ee/app/workers/geo/scheduler/scheduler_worker.rb

@@ -4,6 +4,7 @@ module Geo
       include ApplicationWorker
       include GeoQueue
       include ExclusiveLeaseGuard
+      include ::Gitlab::Geo::LogHelpers
       include ::Gitlab::Utils::StrongMemoize
 
       DB_RETRIEVE_BATCH_SIZE = 1000
@@ -68,7 +69,14 @@ module Geo
 
       private
 
+      # Subclasses should override this method to provide additional metadata
+      # in log messages
       def worker_metadata
+        {}
+      end
+
+      def base_log_data(message)
+        super(message).merge(worker_metadata)
       end
 
       def db_retrieve_batch_size
@@ -185,18 +193,6 @@ module Geo
           Gitlab::Geo.current_node_enabled?
         end
       end
-
-      def log_info(message, extra_args = {})
-        args = { class: self.class.name, message: message }.merge(extra_args)
-        args.merge!(worker_metadata) if worker_metadata
-        Gitlab::Geo::Logger.info(args)
-      end
-
-      def log_error(message, extra_args = {})
-        args = { class: self.class.name, message: message }.merge(extra_args)
-        args.merge!(worker_metadata) if worker_metadata
-        Gitlab::Geo::Logger.error(args)
-      end
     end
   end
 end

ee/spec/workers/geo/scheduler/scheduler_worker_spec.rb

+require 'spec_helper'
+
+describe Geo::Scheduler::SchedulerWorker do
+  it 'includes ::Gitlab::Geo::LogHelpers' do
+    expect(described_class).to include_module(::Gitlab::Geo::LogHelpers)
+  end
+
+  it 'needs many other specs'
+end