def _insert(self, name, value, timestamp, intervals, **kwargs):
    if 'pipeline' in kwargs:
      pipe = kwargs.get('pipeline')
    else:
      pipe = self._client.pipeline(transaction=False)

    for interval,config in self._intervals.iteritems():
      timestamps = self._normalize_timestamps(timestamp, intervals, config)
      for tstamp in timestamps:
        self._insert_data(name, value, tstamp, interval, config, pipe,
          ttl_batch=kwargs.get('ttl_batch'))

    if 'pipeline' not in kwargs:
      pipe.execute()
1 2 4
dataset/ETHPy150Open agoragames/kairos/kairos/redis_backend.py/RedisBackend._insert--crossover with--dataset/ETHPy150Open cloudera/hue/desktop/core/ext-py/lxml-3.3.6/benchmark/bench_objectify.py/BenchMark.bench_attribute_assign_string