@@ -87,6 +87,7 @@ def _read_args(argv: list[str] | None = None) -> argparse.Namespace:
87
87
parser .add_argument (
88
88
"--leanvec_dims" , help = "LeanVec dimensionality" , type = int
89
89
)
90
+ parser .add_argument ("--no_save" , action = "store_true" )
90
91
return parser .parse_args (argv )
91
92
92
93
@@ -139,7 +140,8 @@ def main(argv: str | None = None) -> None:
139
140
np .save (args .out_dir / (name + ".ingest.npy" ), ingest_time )
140
141
if args .num_vectors_delete > 0 :
141
142
np .save (args .out_dir / (name + ".delete" ), delete_time )
142
- save (index , args .out_dir , name )
143
+ if not args .no_save :
144
+ save (index , args .out_dir , name )
143
145
144
146
145
147
def build_dynamic (
@@ -301,6 +303,14 @@ def build_dynamic(
301
303
start = time .perf_counter ()
302
304
index .delete (ids_to_delete )
303
305
delete_time [batch_idx + 1 ] = time .perf_counter () - start
306
+ if num_batches :
307
+ add_time_mean = np .mean (ingest_time [1 :])
308
+ add_time_rsd = (
309
+ np .std (ingest_time [1 :], ddof = min (1 , num_batches - 1 ))
310
+ / add_time_mean
311
+ )
312
+ logger .info ({"add_time" : {"mean" : add_time_mean , "rsd" : add_time_rsd }})
313
+ logger .info ({"build_and_add_time" : np .sum (ingest_time )})
304
314
305
315
name = "__" .join (
306
316
(
0 commit comments