diff --git a/src/aliby/broken_pipeline.py b/src/aliby/broken_pipeline.py index ab287da085c637a42871043753fc78a1d914afc5..184747efe5dc58e069a61cae575982a3b72f544b 100644 --- a/src/aliby/broken_pipeline.py +++ b/src/aliby/broken_pipeline.py @@ -339,6 +339,7 @@ class Pipeline(ProcessABC): tiler_writer = TilerWriter(out_file) baby_writer = LinearBabyWriter(out_file) babystate_writer = StateWriter(out_file) + breakpoint() # start pipeline initialise_tensorflow() frac_clogged_traps = 0.0 @@ -394,9 +395,9 @@ class Pipeline(ProcessABC): ) baby_writer.write( data=result, - tp=i, overwrite=["mother_assign"], meta={"last_processed": i}, + tp=i, ) babystate_writer.write( data=babyrunner.crawler.tracker_states, diff --git a/src/aliby/pipeline.py b/src/aliby/pipeline.py index ace28169afcb5f6cd2163c6ce702c4169403e7f9..6d70d16d8809e195cec042c7977ede484d118d62 100644 --- a/src/aliby/pipeline.py +++ b/src/aliby/pipeline.py @@ -420,7 +420,6 @@ class Pipeline(ProcessABC): "state": loaded_writers["state"].datatypes.keys(), "baby": ["mother_assign"], } - breakpoint() # START PIPELINE frac_clogged_traps = 0.0