code: def store_pulse_jobs(pulse_job, exchange, routing_key):
      
      newrelic.agent.add_custom_parameter("exchange", exchange)
      newrelic.agent.add_custom_parameter("routing_key", routing_key)
  
      JobLoader().process_job(pulse_job)
docs: Fetches the jobs pending from pulse exchanges and loads them.