diff --git a/modal/_container_io_manager.py b/modal/_container_io_manager.py index 4007b8cde..106c8baa5 100644 --- a/modal/_container_io_manager.py +++ b/modal/_container_io_manager.py @@ -152,7 +152,6 @@ def call_finalized_function(self) -> Any: logger.debug(f"Finished input {self.input_ids} (async)") return res - @synchronizer.no_io_translation async def format_outputs( self, container_io_manager: "_ContainerIOManager", started_at: float, data_format: int, **kwargs ) -> List[api_pb2.FunctionPutOutputsItem]: @@ -575,7 +574,6 @@ async def run_inputs_outputs( for _ in range(input_concurrency): await self._semaphore.acquire() - @synchronizer.no_io_translation async def _push_output( self, outputs: List[api_pb2.FunctionPutOutputsItem],