From c3bf961753b3bff805988a81c92f266451439caa Mon Sep 17 00:00:00 2001 From: Peter Swain <peter.swain@ed.ac.uk> Date: Sat, 24 Feb 2024 12:26:27 +0000 Subject: [PATCH] fix(pipeline): deleted breakpoint --- src/aliby/broken_pipeline.py | 3 ++- src/aliby/pipeline.py | 1 - 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/aliby/broken_pipeline.py b/src/aliby/broken_pipeline.py index ab287da..184747e 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 ace2816..6d70d16 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 -- GitLab