werror for examples (#2756)

* werror for examples

* Address initial warnings in examples

* read_next?

* oops

* isort

Author: ethanglaser

examples/daal4py/readcsv.py

@@ -14,19 +14,23 @@
 # limitations under the License.
 # ==============================================================================
 
-from importlib.machinery import SourceFileLoader
+from importlib.util import module_from_spec, spec_from_file_location
 from pathlib import Path
 
 utils_path = Path(__file__).parent.parent / "utils"
 
-readcsv = SourceFileLoader("readcsv", str(utils_path / "readcsv.py")).load_module()
+spec = spec_from_file_location("readcsv", str(utils_path / "readcsv.py"))
+readcsv = module_from_spec(spec)
+spec.loader.exec_module(readcsv)
 
 np_read_csv = readcsv.np_read_csv
 pd_read_csv = readcsv.pd_read_csv
 csr_read_csv = readcsv.csr_read_csv
+read_next = readcsv.read_next
 
 __all__ = [
     "np_read_csv",
     "pd_read_csv",
     "csr_read_csv",
+    "read_next",
 ]

examples/mb/readcsv.py

@@ -14,12 +14,14 @@
 # limitations under the License.
 # ==============================================================================
 
-from importlib.machinery import SourceFileLoader
+from importlib.util import module_from_spec, spec_from_file_location
 from pathlib import Path
 
 utils_path = Path(__file__).parent.parent / "utils"
 
-readcsv = SourceFileLoader("readcsv", str(utils_path / "readcsv.py")).load_module()
+spec = spec_from_file_location("readcsv", str(utils_path / "readcsv.py"))
+readcsv = module_from_spec(spec)
+spec.loader.exec_module(readcsv)
 
 np_read_csv = readcsv.np_read_csv
 pd_read_csv = readcsv.pd_read_csv

examples/sklearnex/knn_bf_classification_spmd.py

@@ -47,8 +47,8 @@ def generate_X_y(par, seed):
         "SPMD execution mode is implemented only for this device type."
     )
 
-params_train = {"ns": 100000, "nf": 8}
-params_test = {"ns": 100, "nf": 8}
+params_train = {"ns": 100000, "nf": 3}
+params_test = {"ns": 100, "nf": 3}
 
 X_train, y_train = generate_X_y(params_train, rank)
 X_test, y_test = generate_X_y(params_test, rank + 99)

onedal/_device_offload.py

@@ -131,6 +131,7 @@ def wrapper_impl(*args, **kwargs):
             self
             and self.__class__.__name__ in ("KNeighborsClassifier", "KNeighborsRegressor")
             and func.__name__ == "fit"
+            and _get_config()["use_raw_input"] is True
         )
         if override_raw_input:
             pretty_name = f"{self.__class__.__name__}.{func.__name__}"

tests/run_examples.py

@@ -221,10 +221,12 @@ def get_exe_cmd(ex, args):
             return None
     if not args.nodist and ex.endswith("spmd.py"):
         if IS_WIN:
-            return 'mpiexec -localonly -n 4 "' + sys.executable + '" "' + ex + '"'
-        return 'mpirun -n 4 "' + sys.executable + '" "' + ex + '"'
+            return (
+                'mpiexec -localonly -n 4 "' + sys.executable + '" -W error "' + ex + '"'
+            )
+        return 'mpirun -n 4 "' + sys.executable + '" -W error "' + ex + '"'
     else:
-        return '"' + sys.executable + '" "' + ex + '"'
+        return '"' + sys.executable + '" -W error "' + ex + '"'
 
 
 def run(exdir, logdir, args):