change warning to error

ibis-project · Jul 16, 2024 · f510d6a · f510d6a
1 parent 3a8e39d
commit f510d6a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/ibis/backends/pyspark/__init__.py b/ibis/backends/pyspark/__init__.py
@@ -1080,7 +1080,7 @@ def read_csv_dir(
                 path, inferSchema=inferSchema, header=header, **kwargs
             )
             if watermark is not None:
-                warnings.warn("Watermark is not supported in batch mode")
+                raise com.IbisInputError("Watermark is not supported in batch mode")
         elif self.mode == "streaming":
             spark_df = self._session.readStream.csv(
                 path, inferSchema=inferSchema, header=header, **kwargs
@@ -1134,7 +1134,7 @@ def read_parquet_dir(
                 spark_df = spark_df.schema(PySparkSchema.from_ibis(schema))
             spark_df = spark_df.parquet(path, **kwargs)
             if watermark is not None:
-                warnings.warn("Watermark is not supported in batch mode")
+                raise com.IbisInputError("Watermark is not supported in batch mode")
         elif self.mode == "streaming":
             spark_df = self._session.readStream
             if schema is not None:
@@ -1183,7 +1183,7 @@ def read_json_dir(
         if self.mode == "batch":
             spark_df = self._session.read.json(path, **kwargs)
             if watermark is not None:
-                warnings.warn("Watermark is not supported in batch mode")
+                raise com.IbisInputError("Watermark is not supported in batch mode")
         elif self.mode == "streaming":
             spark_df = self._session.readStream.json(path, **kwargs)
             if watermark is not None: