Apply comment

Signed-off-by: Igoshev, Yaroslav <yaroslav.igoshev@intel.com>

modin/conftest.py

@@ -234,6 +234,17 @@ def from_arrow(cls, at, data_cls):
     def free(self):
         pass
 
+    def to_dataframe(self, nan_as_null: bool = False, allow_copy: bool = True) -> dict:
+        raise NotImplementedError(
+            "The selected execution does not implement the DataFrame exchange protocol."
+        )
+
+    @classmethod
+    def from_dataframe(cls, df, data_cls):
+        raise NotImplementedError(
+            "The selected execution does not implement the DataFrame exchange protocol."
+        )
+
     to_pandas = PandasQueryCompiler.to_pandas
     default_to_pandas = PandasQueryCompiler.default_to_pandas
 

modin/core/storage_formats/base/query_compiler.py

@@ -365,6 +365,7 @@ def to_numpy(self, **kwargs):  # noqa: PR02
 
     # Dataframe exchange protocol
 
+    @abc.abstractmethod
     def to_dataframe(self, nan_as_null: bool = False, allow_copy: bool = True) -> dict:
         """
         Get a DataFrame exchange protocol object representing data of the Modin DataFrame.
@@ -390,11 +391,10 @@ def to_dataframe(self, nan_as_null: bool = False, allow_copy: bool = True) -> di
         dict
             A dictionary object following the DataFrame protocol specification.
         """
-        raise NotImplementedError(
-            "The selected execution does not implement the DataFrame exchange protocol."
-        )
+        pass
 
     @classmethod
+    @abc.abstractmethod
     def from_dataframe(cls, df, data_cls):
         """
         Build QueryCompiler from a DataFrame object supporting the dataframe exchange protocol `__dataframe__()`.
@@ -412,9 +412,7 @@ def from_dataframe(cls, df, data_cls):
         BaseQueryCompiler
             QueryCompiler containing data from the DataFrame.
         """
-        raise NotImplementedError(
-            "The selected execution does not implement import via the DataFrame exchange protocol."
-        )
+        pass
 
     # END Dataframe exchange protocol
 

modin/core/storage_formats/pandas/query_compiler.py

@@ -264,6 +264,21 @@ def from_pandas(cls, df, data_cls):
     def from_arrow(cls, at, data_cls):
         return cls(data_cls.from_arrow(at))
 
+    # Dataframe exchange protocol
+
+    def to_dataframe(self, nan_as_null: bool = False, allow_copy: bool = True) -> dict:
+        raise NotImplementedError(
+            "The selected execution does not implement the DataFrame exchange protocol yet."
+        )
+
+    @classmethod
+    def from_dataframe(cls, df, data_cls):
+        raise NotImplementedError(
+            "The selected execution does not implement the DataFrame exchange protocol yet."
+        )
+
+    # END Dataframe exchange protocol
+
     index = property(_get_axis(0), _set_axis(0))
     columns = property(_get_axis(1), _set_axis(1))
 

modin/experimental/core/storage_formats/omnisci/query_compiler.py

@@ -201,6 +201,21 @@ def from_arrow(cls, at, data_cls):
             shape_hint = None
         return cls(data_cls.from_arrow(at), shape_hint=shape_hint)
 
+    # Dataframe exchange protocol
+
+    def to_dataframe(self, nan_as_null: bool = False, allow_copy: bool = True) -> dict:
+        raise NotImplementedError(
+            "The selected execution does not implement the DataFrame exchange protocol yet."
+        )
+
+    @classmethod
+    def from_dataframe(cls, df, data_cls):
+        raise NotImplementedError(
+            "The selected execution does not implement the DataFrame exchange protocol yet."
+        )
+
+    # END Dataframe exchange protocol
+
     default_to_pandas = PandasQueryCompiler.default_to_pandas
 
     def copy(self):

modin/test/test_executions_api.py

@@ -32,6 +32,8 @@ def test_base_abstract_methods():
         "from_pandas",
         "from_arrow",
         "default_to_pandas",
+        "from_dataframe",
+        "to_dataframe",
     ]
 
     not_implemented_methods = BASE_EXECUTION.__abstractmethods__.difference(