From 5f0cb8a6ecc86380d099cf594955afbf439cebbd Mon Sep 17 00:00:00 2001 From: Chadwick Boulay Date: Tue, 21 Apr 2026 00:24:26 -0400 Subject: [PATCH] Bump ezmsg to 3.9.0 and eliminate deprecated decoration argument --- pyproject.toml | 2 +- src/ezmsg/baseproc/units.py | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/pyproject.toml b/pyproject.toml index 912ccf8..b7a7e8d 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -12,7 +12,7 @@ readme = "README.md" requires-python = ">=3.10" dynamic = ["version"] dependencies = [ - "ezmsg[axisarray]>=3.7.3", + "ezmsg[axisarray]>=3.9.0", "typing-extensions>=4.0.0", ] diff --git a/src/ezmsg/baseproc/units.py b/src/ezmsg/baseproc/units.py index 154cf67..3ae73e6 100644 --- a/src/ezmsg/baseproc/units.py +++ b/src/ezmsg/baseproc/units.py @@ -186,7 +186,7 @@ def create_processor(self): consumer_type = get_base_consumer_type(self.__class__) self.processor = consumer_type(settings=self.SETTINGS) - @ez.subscriber(INPUT_SIGNAL, zero_copy=True) + @ez.subscriber(INPUT_SIGNAL) async def on_signal(self, message: MessageInType): """ Consume the message. @@ -236,7 +236,7 @@ def create_processor(self): transformer_type = get_base_transformer_type(self.__class__) self.processor = transformer_type(settings=self.SETTINGS) - @ez.subscriber(INPUT_SIGNAL, zero_copy=True) + @ez.subscriber(INPUT_SIGNAL) @ez.publisher(OUTPUT_SIGNAL) @profile_subpub(trace_oldest=False) async def on_signal(self, message: MessageInType) -> typing.AsyncGenerator: @@ -262,7 +262,7 @@ def create_processor(self) -> None: adaptive_transformer_type = get_base_adaptive_transformer_type(self.__class__) self.processor = adaptive_transformer_type(settings=self.SETTINGS) - @ez.subscriber(INPUT_SIGNAL, zero_copy=True) + @ez.subscriber(INPUT_SIGNAL) @ez.publisher(OUTPUT_SIGNAL) @profile_subpub(trace_oldest=False) async def on_signal(self, message: MessageInType) -> typing.AsyncGenerator: @@ -312,7 +312,7 @@ def create_processor(self) -> None: producer_type = get_base_clockdriven_producer_type(self.__class__) self.processor = producer_type(settings=self.SETTINGS) - @ez.subscriber(INPUT_CLOCK, zero_copy=True) + @ez.subscriber(INPUT_CLOCK) @ez.publisher(OUTPUT_SIGNAL) @profile_subpub(trace_oldest=False) async def on_clock(self, clock_tick: LinearAxis) -> typing.AsyncGenerator: @@ -381,7 +381,7 @@ async def on_settings(self, msg: ez.Settings) -> None: self.apply_settings(msg) self.construct_generator() - @ez.subscriber(INPUT_SIGNAL, zero_copy=True) + @ez.subscriber(INPUT_SIGNAL) @ez.publisher(OUTPUT_SIGNAL) @profile_subpub(trace_oldest=False) async def on_signal(self, message: AxisArray) -> typing.AsyncGenerator: