Added GeoBulkNotifyWorker to sidekiq-cron

app/workers/geo_bulk_notify_worker.rb

+class GeoRepositoryUpdateWorker
+  include Sidekiq::Worker
+
+  sidekiq_options queue: :default
+
+
+  def perform
+    return unless Gitlab::Geo.enabled?
+    Geo::NotifyNodesService.new.execute
+  end
+end

app/workers/geo_repository_update_worker.rb

@@ -2,9 +2,9 @@ class GeoRepositoryUpdateWorker
   include Sidekiq::Worker
   include Gitlab::ShellAdapter
 
-  sidekiq_options queue: :gitlab_shell
+  sidekiq_options queue: :default
 
-  attr_accessor :project, :repository, :current_user
+  attr_accessor :project
 
   def perform(project_id)
     @project = Project.find(project_id)

config/gitlab.yml.example

@@ -196,6 +196,11 @@ production: &base
     ldap_sync_worker:
       cron: "30 1 * * *"
 
+    # Gitlab Geo nodes notification worker
+    # NOTE: This will only take effect if Geo is enabled
+    geo_bulk_notify_worker:
+      cron: "*/10 * * * * *"
+
 
   #
   # 2. GitLab CI settings

config/initializers/1_settings.rb

@@ -331,6 +331,9 @@ Settings.cron_jobs['update_all_mirrors_worker']['job_class'] = 'UpdateAllMirrors
 Settings.cron_jobs['ldap_sync_worker'] ||= Settingslogic.new({})
 Settings.cron_jobs['ldap_sync_worker']['cron'] ||= '30 1 * * *'
 Settings.cron_jobs['ldap_sync_worker']['job_class'] = 'LdapSyncWorker'
+Settings.cron_jobs['geo_bulk_notify_worker'] ||= Settingslogic.new({})
+Settings.cron_jobs['geo_bulk_notify_worker']['cron'] ||= '*/10 * * * * *'
+Settings.cron_jobs['geo_bulk_notify_worker']['job_class'] ||= 'GeoBulkNotifyWorker'
 
 #
 # GitLab Shell