def _init_shard(self):
    self.shard_state = model.ShardState.create_new(
        self.mr_spec.mapreduce_id,
        shard_number=self.SHARD_NUMBER)
    self.shard_state.slice_id = self.CURRENT_SLICE_ID
    self.shard_state.put()
    self.shard_id = self.shard_state.shard_id
Called directly by fineuploader on upload completion.
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/test/mapreduce/handlers_test.py/MapperWorkerCallbackHandlerLeaseTest._init_shard--crossover with--dataset/ETHPy150Open buildingenergy/buildingenergy-platform/data_importer/views.py/DataImportBackend.upload_complete