Add related_class ReactiveCachingWorker logging

This adds the `meta.related_class` keyword to the job hash. This will
make it easier to determine what different kinds of work this worker
is doing.

app/workers/reactive_caching_worker.rb

@@ -13,6 +13,11 @@ class ReactiveCachingWorker # rubocop:disable Scalability/IdempotentWorker
   urgency :high
   worker_resource_boundary :cpu
 
+  def self.context_for_arguments(arguments)
+    class_name, *_other_args = arguments
+    Gitlab::ApplicationContext.new(related_class: class_name)
+  end
+
   def perform(class_name, id, *args)
     klass = begin
       class_name.constantize

doc/api/graphql/reference/gitlab_schema.graphql

@@ -62,6 +62,11 @@ input AdminSidekiqQueuesDeleteJobsInput {
   """
   queueName: String!
 
+  """
+  Delete jobs matching related_class in the context metadata
+  """
+  relatedClass: String
+
   """
   Delete jobs matching root_namespace in the context metadata
   """

doc/api/graphql/reference/gitlab_schema.json

@@ -181,6 +181,16 @@
               },
               "defaultValue": null
             },
+            {
+              "name": "relatedClass",
+              "description": "Delete jobs matching related_class in the context metadata",
+              "type": {
+                "kind": "SCALAR",
+                "name": "String",
+                "ofType": null
+              },
+              "defaultValue": null
+            },
             {
               "name": "queueName",
               "description": "The name of the queue to delete jobs from",

lib/gitlab/application_context.rb

@@ -11,7 +11,8 @@ module Gitlab
       Attribute.new(:project, Project),
       Attribute.new(:namespace, Namespace),
       Attribute.new(:user, User),
-      Attribute.new(:caller_id, String)
+      Attribute.new(:caller_id, String),
+      Attribute.new(:related_class, String)
     ].freeze
 
     def self.with_context(args, &block)
@@ -39,6 +40,7 @@ module Gitlab
         hash[:project] = -> { project_path } if set_values.include?(:project)
         hash[:root_namespace] = -> { root_namespace_path } if include_namespace?
         hash[:caller_id] = caller_id if set_values.include?(:caller_id)
+        hash[:related_class] = related_class if set_values.include?(:related_class)
       end
     end
 

spec/workers/reactive_caching_worker_spec.rb

@@ -28,4 +28,14 @@ describe ReactiveCachingWorker do
       end
     end
   end
+
+  describe 'worker context' do
+    it 'sets the related class on the job' do
+      described_class.perform_async('Environment', 1, 'other', 'argument')
+
+      scheduled_job = described_class.jobs.first
+
+      expect(scheduled_job).to include('meta.related_class' => 'Environment')
+    end
+  end
 end