@@ -202,7 +202,7 @@ def create_empty(
202
202
buffer_prototype = default_buffer_prototype ()
203
203
index = _ShardIndex .create_empty (chunks_per_shard )
204
204
obj = cls ()
205
- obj .buf = buffer_prototype .buffer .create_zero_length ()
205
+ obj .buf = buffer_prototype .buffer .Delayed . create_zero_length ()
206
206
obj .index = index
207
207
return obj
208
208
@@ -585,16 +585,15 @@ async def _encode_partial_single(
585
585
chunks_per_shard = self ._get_chunks_per_shard (shard_spec )
586
586
chunk_spec = self ._get_chunk_spec (shard_spec )
587
587
588
- shard_read = await self ._load_full_shard_maybe (
589
- byte_getter = byte_setter ,
590
- prototype = chunk_spec .prototype ,
591
- chunks_per_shard = chunks_per_shard ,
588
+ shard_dict = _MergingShardBuilder (
589
+ await self ._load_full_shard_maybe (
590
+ byte_getter = byte_setter ,
591
+ prototype = chunk_spec .prototype ,
592
+ chunks_per_shard = chunks_per_shard ,
593
+ )
594
+ or _ShardReader .create_empty (chunks_per_shard ),
595
+ _ShardBuilder .create_empty (chunks_per_shard ),
592
596
)
593
- shard_build = _ShardBuilder .create_empty (chunks_per_shard )
594
- if shard_read :
595
- shard_dict = _MergingShardBuilder (shard_read , shard_build )
596
- else :
597
- shard_dict = shard_build
598
597
599
598
indexer = list (
600
599
get_indexer (
0 commit comments