docs: def stop(self):
          """Terminates the forked process.
  
          Only valid if started as a fork, because... well you wouldn't get here otherwise.
          :return:
          """
          distributed_logger.info('Stopping metrics aggregator')
          self.process.terminate()
          self.process.join()
          distributed_logger.info('Stopped metrics aggregator')