def _SetConnection(connection):
  _thread_local.connection = connection

  os.environ[_ENV_KEY] = '1'
Returns the next scheduled item to be executed.
dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/api/datastore.py/_SetConnection--crossover with--dataset/ETHPy150Open ReactiveX/RxPY/rx/concurrency/virtualtimescheduler.py/VirtualTimeScheduler.get_next