code: def store_pulse_pushes(body, exchange, routing_key):
      
      newrelic.agent.add_custom_parameter("exchange", exchange)
      newrelic.agent.add_custom_parameter("routing_key", routing_key)
  
      PushLoader().process(body, exchange)
docs: Fetches the pushes pending from pulse exchanges and loads them.