def testScheduleSlice_Countdown(self):
    countdown = 60 * 60
    self.handler._schedule_slice(
        self.shard_state,
        model.TransientShardState(
            "/mapreduce", self.mapreduce_spec,
            self.shard_id, 123, mock.Mock(), mock.Mock()),
        countdown=countdown)

    tasks = self.taskqueue.GetTasks("default")
    self.assertEquals(1, len(tasks))
    self.verify_shard_task(tasks[0], self.shard_id, 123, countdown=countdown)
Store dask arrays in array-like objects, overwrite data in target
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/test/mapreduce/handlers_test.py/MapperWorkerCallbackHandlerTest.testScheduleSlice_Countdown--crossover with--dataset/ETHPy150Open dask/dask/dask/array/core.py/store