diff --git a/aliby/pipeline.py b/aliby/pipeline.py index 4d4cc57cebef6e18ea77ef39a13feee84f182a40..8fe7e9e1bf1a190bbbb1744bd864b23e173c99d3 100644 --- a/aliby/pipeline.py +++ b/aliby/pipeline.py @@ -282,13 +282,13 @@ class Pipeline(ProcessABC): ) for k, v in process_from.items(): if not ow[k]: - - process_from[k] = f[ - self.writer_groups[k][-1] - ].attrs.get( - "last_processed", - legacy_get_last_tp[k](f), - ) + process_from[k] = legacy_get_last_tp[k](f) + # process_from[k] = f[ + # self.writer_groups[k][-1] + # ].attrs.get( + # "last_processed", + # legacy_get_last_tp[k](f), + # ) process_from[k] += 1 # get state array if not ow["baby"]: