code: def count_by_state_unsynced(self, arg):
          
          if self.kill_timeout is not None:
              self.delete_running(self.kill_timeout)
          return super(CMongoTrials, self).count_by_state_unsynced(arg)
docs: Extends the original object in order to inject checking
          for stalled jobs and killing them if they are running for too long