diff --git a/src/agora/io/signal.py b/src/agora/io/signal.py index 0708c52601a974c57e646477cd71267c4b732dad..06bae6e166156f644523490feb37ebb44f1cca50 100644 --- a/src/agora/io/signal.py +++ b/src/agora/io/signal.py @@ -191,7 +191,6 @@ class Signal(BridgeH5): else set(merged.index) ) # TODO : the following needs clarifying - breakpoint() with h5py.File(self.filename, "r") as f: if "modifiers/picks" in f and picks: if picks: diff --git a/src/agora/utils/merge.py b/src/agora/utils/merge.py index ce24d3776a38aeaa82aff3722013af0ca7d18238..bc7cb4b171069fb42a76c325590be12b1eb81485 100644 --- a/src/agora/utils/merge.py +++ b/src/agora/utils/merge.py @@ -3,19 +3,11 @@ Functions to efficiently merge rows in DataFrames. """ import typing as t -from copy import copy import numpy as np import pandas as pd - from utils_find_1st import cmp_larger, find_1st -# from agora.utils.indexing import ( -# index_isin, -# compare_indices, -# validate_association, -# ) - from agora.utils.indexing import index_isin diff --git a/src/aliby/pipeline.py b/src/aliby/pipeline.py index 526388837c8a54408024e757645754010c0fc3af..77bcc356273820bdbfc97718b4a5b1c1826d9564 100644 --- a/src/aliby/pipeline.py +++ b/src/aliby/pipeline.py @@ -10,7 +10,6 @@ from pathlib import Path import h5py import numpy as np -import pandas as pd from pathos.multiprocessing import Pool from tqdm import tqdm @@ -18,11 +17,7 @@ from agora.abc import ParametersABC, ProcessABC from agora.io.metadata import MetaData, parse_logfiles from agora.io.reader import StateReader from agora.io.signal import Signal -from agora.io.writer import ( - LinearBabyWriter, - StateWriter, - TilerWriter, -) +from agora.io.writer import LinearBabyWriter, StateWriter, TilerWriter from aliby.baby_client import BabyParameters, BabyRunner from aliby.haystack import initialise_tf from aliby.io.dataset import dispatch_dataset