@@ -249,6 +249,7 @@ def append(self, arctic_lib, version, symbol, item, previous_version, dtype=None
249
249
item = np .concatenate ([old_arr , item ])
250
250
version ['up_to' ] = len (item )
251
251
version ['sha' ] = self .checksum (item )
252
+ version ['base_sha' ] = version ['sha' ]
252
253
self ._do_write (collection , version , symbol , item , previous_version )
253
254
else :
254
255
version ['dtype' ] = previous_version ['dtype' ]
@@ -259,6 +260,7 @@ def append(self, arctic_lib, version, symbol, item, previous_version, dtype=None
259
260
def _do_append (self , collection , version , symbol , item , previous_version ):
260
261
261
262
data = item .tostring ()
263
+ version ['base_sha' ] = previous_version ['base_sha' ]
262
264
version ['up_to' ] = previous_version ['up_to' ] + len (item )
263
265
if len (item ) > 0 :
264
266
version ['segment_count' ] = previous_version ['segment_count' ] + 1
@@ -380,6 +382,7 @@ def write(self, arctic_lib, version, symbol, item, previous_version, dtype=None)
380
382
self ._do_append (collection , version , symbol , item [previous_version ['up_to' ]:], previous_version )
381
383
return
382
384
385
+ version ['base_sha' ] = version ['sha' ]
383
386
self ._do_write (collection , version , symbol , item , previous_version )
384
387
385
388
def _do_write (self , collection , version , symbol , item , previous_version , segment_offset = 0 ):
0 commit comments