add first batch of processes

Former-commit-id: fe142d87a141891715f5116873dd7ae2c0bb767f

core/group.py

@@ -105,12 +105,10 @@ class Group(ProcessABC):
         self.concat_signals()
         # processed_signals = self.process_signals(grouped_signals)
 
-        return concated_signals
+        return self.concated_signals
         # return processed_signals
 
 
-# "/shared_libs/pipeline-core/scripts/data/ph_calibration_dual_phl_ura8_5_04_5_83_7_69_7_13_6_59__01"
-# simulate poses
 poses = [
     x.name.split("store")[0]
     for x in Path(

core/processes/births.py

+#!/usr/bin/env python3

core/processes/dsignal.py

+from postprocessor.core.processes.base import ParametersABC, ProcessABC
+from postprocessor.core.functions.tracks import clean_tracks, merge_tracks, join_tracks
+
+
+class dSignalParameters(ParametersABC):
+    """
+    :window: Number of timepoints to consider for signal.
+    """
+
+    def __init__(self, window):
+        super().__init__()
+
+    @classmethod
+    def default(cls):
+        return cls.from_dict({"window": 3})
+
+
+class dSignal(ProcessABC):
+    """
+    Calculate the change in a signal depending on a window
+    """
+
+    def __init__(self, parameters: ParametersTemplate):
+        super().__init__(parameters)
+
+    def run(self, signal: pd.DataFrame):
+        return signal.rolling(window=self.parameters.window, axis=1).mean().diff(axis=1)

examples/group.py

+from pathlib import Path
+
+from postprocessor.core.group import GroupParameters, Group
+
+poses = [
+    x.name.split("store")[0]
+    for x in Path(
+        "/shared_libs/pipeline-core/scripts/data/ph_calibration_dual_phl_ura8_5_04_5_83_7_69_7_13_6_59__01"
+    ).rglob("*")
+    if x.name != "images.h5"
+]
+
+gr = Group(
+    GroupParameters(
+        signals=["/extraction/general/None/area", "/extraction/mCherry/np_max/median"]
+    )
+)
+gr.run(
+    central_store="/shared_libs/pipeline-core/scripts/data/ph_calibration_dual_phl_ura8_5_04_5_83_7_69_7_13_6_59__01",
+    poses=poses,
+)

examples/signals.py

+from postprocessor.core.io.signals import Signal
+
+signal = Signal(
+    "/shared_libs/pipeline-core/scripts/data/ph_calibration_dual_phl_ura8_5_04_5_83_7_69_7_13_6_59__01/ph_5_04_001store.h5"
+)