fix tests

Signed-off-by: SimoTw <[email protected]>

python/ray/air/_internal/device_manager/torch_device_manager.py

@@ -20,7 +20,6 @@ def get_devices(self) -> List[torch.device]:
         """Gets the correct torch device configured for this process"""
         raise NotImplementedError
 
-    @abc.abstractmethod
     def set_device(self, device: Union[torch.device, int, str, None]):
         """Set the correct device for this process"""
         raise NotImplementedError
@@ -30,7 +29,6 @@ def supports_stream(self) -> bool:
         """Validate if the device type support create a stream"""
         raise NotImplementedError
 
-    @abc.abstractmethod
     def create_stream(self, device: torch.device):
         """Create a device stream"""
         raise NotImplementedError
@@ -42,7 +40,6 @@ def get_stream_context(self, stream):
         """
         raise NotImplementedError
 
-    @abc.abstractmethod
     def get_current_stream(self):
         """Get current stream on accelerators like torch.cuda.current_stream"""
         raise NotImplementedError

python/ray/data/preprocessor.py

@@ -25,7 +25,7 @@ class PreprocessorNotFittedException(RuntimeError):
 
 
 @PublicAPI(stability="beta")
-class Preprocessor(abc.ABC):
+class Preprocessor(abc.ABC):  # noqa: B024
     """Implements an ML preprocessing operation.
 
     Preprocessors are stateful objects that can be fitted against a Dataset and used
@@ -184,7 +184,6 @@ def transform_batch(self, data: "DataBatchType") -> "DataBatchType":
         return self._transform_batch(data)
 
     @DeveloperAPI
-    @abc.abstractmethod
     def _fit(self, ds: "Dataset") -> "Preprocessor":
         """Sub-classes should override this instead of fit()."""
         raise NotImplementedError()