refactor(all): unify method signatures across backends

ibis/backends/__init__.py

@@ -337,7 +337,7 @@ def to_torch(
         }
 
     def read_parquet(
-        self, path: str | Path, table_name: str | None = None, **kwargs: Any
+        self, path: str | Path, /, *, table_name: str | None = None, **kwargs: Any
     ) -> ir.Table:
         """Register a parquet file as a table in the current backend.
 
@@ -362,14 +362,15 @@ def read_parquet(
         )
 
     def read_csv(
-        self, path: str | Path, table_name: str | None = None, **kwargs: Any
+        self, path: str | Path, /, *, table_name: str | None = None, **kwargs: Any
     ) -> ir.Table:
         """Register a CSV file as a table in the current backend.
 
         Parameters
         ----------
         path
-            The data source. A string or Path to the CSV file.
+            The data source(s). A string or Path to the CSV file or directory
+            containing CSV files.
         table_name
             An optional name to use for the created table. This defaults to
             a sequentially generated name.
@@ -387,7 +388,7 @@ def read_csv(
         )
 
     def read_json(
-        self, path: str | Path, table_name: str | None = None, **kwargs: Any
+        self, path: str | Path, /, *, table_name: str | None = None, **kwargs: Any
     ) -> ir.Table:
         """Register a JSON file as a table in the current backend.
 
@@ -412,13 +413,13 @@ def read_json(
         )
 
     def read_delta(
-        self, source: str | Path, table_name: str | None = None, **kwargs: Any
+        self, path: str | Path, /, *, table_name: str | None = None, **kwargs: Any
     ):
         """Register a Delta Lake table in the current database.
 
         Parameters
         ----------
-        source
+        path
             The data source. Must be a directory
             containing a Delta Lake table.
         table_name
@@ -492,7 +493,8 @@ def to_parquet_dir(
         expr
             The ibis expression to execute and persist to parquet.
         directory
-            The data source. A string or Path to the directory where the parquet file will be written.
+            A string or Path to the directory where the parquet file will be
+            written.
         params
             Mapping of scalar parameter expressions to value.
         **kwargs
@@ -587,7 +589,7 @@ def to_delta(
 
 class CanListCatalog(abc.ABC):
     @abc.abstractmethod
-    def list_catalogs(self, like: str | None = None) -> list[str]:
+    def list_catalogs(self, *, like: str | None = None) -> list[str]:
         """List existing catalogs in the current connection.
 
         ::: {.callout-note}
@@ -623,7 +625,7 @@ def current_catalog(self) -> str:
 
 class CanCreateCatalog(CanListCatalog):
     @abc.abstractmethod
-    def create_catalog(self, name: str, force: bool = False) -> None:
+    def create_catalog(self, name: str, /, *, force: bool = False) -> None:
         """Create a new catalog.
 
         ::: {.callout-note}
@@ -647,7 +649,7 @@ def create_catalog(self, name: str, force: bool = False) -> None:
         """
 
     @abc.abstractmethod
-    def drop_catalog(self, name: str, force: bool = False) -> None:
+    def drop_catalog(self, name: str, /, *, force: bool = False) -> None:
         """Drop a catalog with name `name`.
 
         ::: {.callout-note}
@@ -674,7 +676,7 @@ def drop_catalog(self, name: str, force: bool = False) -> None:
 class CanListDatabase(abc.ABC):
     @abc.abstractmethod
     def list_databases(
-        self, like: str | None = None, catalog: str | None = None
+        self, *, like: str | None = None, catalog: str | None = None
     ) -> list[str]:
         """List existing databases in the current connection.
 
@@ -715,7 +717,7 @@ def current_database(self) -> str:
 class CanCreateDatabase(CanListDatabase):
     @abc.abstractmethod
     def create_database(
-        self, name: str, catalog: str | None = None, force: bool = False
+        self, name: str, /, *, catalog: str | None = None, force: bool = False
     ) -> None:
         """Create a database named `name` in `catalog`.
 
@@ -733,7 +735,7 @@ def create_database(
 
     @abc.abstractmethod
     def drop_database(
-        self, name: str, catalog: str | None = None, force: bool = False
+        self, name: str, /, *, catalog: str | None = None, force: bool = False
     ) -> None:
         """Drop the database with `name` in `catalog`.
 
@@ -777,15 +779,15 @@ class CanCreateSchema(CanListSchema):
     def create_schema(
         self, name: str, database: str | None = None, force: bool = False
     ) -> None:
-        self.create_database(name=name, catalog=database, force=force)
+        self.create_database(name, catalog=database, force=force)
 
     @util.deprecated(
         instead="Use `drop_database` instead", as_of="9.0", removed_in="10.0"
     )
     def drop_schema(
         self, name: str, database: str | None = None, force: bool = False
     ) -> None:
-        self.drop_database(name=name, catalog=database, force=force)
+        self.drop_database(name, catalog=database, force=force)
 
 
 class BaseBackend(abc.ABC, _FileIOHandler):
@@ -934,7 +936,7 @@ def _filter_with_like(values: Iterable[str], like: str | None = None) -> list[st
 
     @abc.abstractmethod
     def list_tables(
-        self, like: str | None = None, database: tuple[str, str] | str | None = None
+        self, *, like: str | None = None, database: tuple[str, str] | str | None = None
     ) -> list[str]:
         """Return the list of table names in the current database.
 
@@ -972,7 +974,7 @@ def list_tables(
 
     @abc.abstractmethod
     def table(
-        self, name: str, database: tuple[str, str] | str | None = None
+        self, name: str, /, *, database: tuple[str, str] | str | None = None
     ) -> ir.Table:
         """Construct a table expression.
 
@@ -1075,18 +1077,21 @@ def _run_pre_execute_hooks(self, expr: ir.Expr) -> None:
     def compile(
         self,
         expr: ir.Expr,
+        /,
+        *,
         params: Mapping[ir.Expr, Any] | None = None,
     ) -> Any:
         """Compile an expression."""
         return self.compiler.to_sql(expr, params=params)
 
-    def execute(self, expr: ir.Expr) -> Any:
+    def execute(self, expr: ir.Expr, /) -> Any:
         """Execute an expression."""
 
     @abc.abstractmethod
     def create_table(
         self,
         name: str,
+        /,
         obj: pd.DataFrame | pa.Table | ir.Table | None = None,
         *,
         schema: ibis.Schema | None = None,
@@ -1126,6 +1131,7 @@ def create_table(
     def drop_table(
         self,
         name: str,
+        /,
         *,
         database: str | None = None,
         force: bool = False,
@@ -1165,6 +1171,7 @@ def rename_table(self, old_name: str, new_name: str) -> None:
     def create_view(
         self,
         name: str,
+        /,
         obj: ir.Table,
         *,
         database: str | None = None,
@@ -1193,7 +1200,7 @@ def create_view(
 
     @abc.abstractmethod
     def drop_view(
-        self, name: str, *, database: str | None = None, force: bool = False
+        self, name: str, /, *, database: str | None = None, force: bool = False
     ) -> None:
         """Drop a view.
 

ibis/backends/bigquery/__init__.py

@@ -246,7 +246,7 @@ def load(file: str) -> None:
         return self.table(table_name, database=(catalog, database))
 
     def read_parquet(
-        self, path: str | Path, table_name: str | None = None, **kwargs: Any
+        self, path: str | Path, /, *, table_name: str | None = None, **kwargs: Any
     ):
         """Read Parquet data into a BigQuery table.
 
@@ -274,7 +274,7 @@ def read_parquet(
         )
 
     def read_csv(
-        self, path: str | Path, table_name: str | None = None, **kwargs: Any
+        self, path: str | Path, /, *, table_name: str | None = None, **kwargs: Any
     ) -> ir.Table:
         """Read CSV data into a BigQuery table.
 
@@ -303,7 +303,7 @@ def read_csv(
         return self._read_file(path, table_name=table_name, job_config=job_config)
 
     def read_json(
-        self, path: str | Path, table_name: str | None = None, **kwargs: Any
+        self, path: str | Path, /, *, table_name: str | None = None, **kwargs: Any
     ) -> ir.Table:
         """Read newline-delimited JSON data into a BigQuery table.
 
@@ -533,6 +533,8 @@ def dataset_id(self):
     def create_database(
         self,
         name: str,
+        /,
+        *,
         catalog: str | None = None,
         force: bool = False,
         collate: str | None = None,
@@ -560,6 +562,8 @@ def create_database(
     def drop_database(
         self,
         name: str,
+        /,
+        *,
         catalog: str | None = None,
         force: bool = False,
         cascade: bool = False,
@@ -575,7 +579,7 @@ def drop_database(
         self.raw_sql(stmt.sql(self.name))
 
     def table(
-        self, name: str, database: str | None = None, schema: str | None = None
+        self, name: str, /, *, database: str | None = None, schema: str | None = None
     ) -> ir.Table:
         table_loc = self._warn_and_create_table_loc(database, schema)
         table = sg.parse_one(f"`{name}`", into=sge.Table, read=self.name)
@@ -686,6 +690,8 @@ def current_database(self) -> str | None:
     def compile(
         self,
         expr: ir.Expr,
+        /,
+        *,
         limit: str | None = None,
         params=None,
         pretty: bool = True,
@@ -706,7 +712,7 @@ def compile(
         self._log(sql)
         return sql
 
-    def execute(self, expr, params=None, limit="default", **kwargs):
+    def execute(self, expr, /, *, params=None, limit="default", **kwargs):
         """Compile and execute the given Ibis expression.
 
         Compile and execute Ibis expression using this backend client
@@ -753,7 +759,9 @@ def execute(self, expr, params=None, limit="default", **kwargs):
     def insert(
         self,
         table_name: str,
+        /,
         obj: pd.DataFrame | ir.Table | list | dict,
+        *,
         schema: str | None = None,
         database: str | None = None,
         overwrite: bool = False,
@@ -866,6 +874,7 @@ def list_databases(
 
     def list_tables(
         self,
+        *,
         like: str | None = None,
         database: tuple[str, str] | str | None = None,
         schema: str | None = None,
@@ -916,6 +925,7 @@ def version(self):
     def create_table(
         self,
         name: str,
+        /,
         obj: ir.Table
         | pd.DataFrame
         | pa.Table
@@ -1069,6 +1079,7 @@ def create_table(
     def drop_table(
         self,
         name: str,
+        /,
         *,
         schema: str | None = None,
         database: tuple[str | str] | str | None = None,
@@ -1090,6 +1101,7 @@ def drop_table(
     def create_view(
         self,
         name: str,
+        /,
         obj: ir.Table,
         *,
         schema: str | None = None,
@@ -1116,6 +1128,7 @@ def create_view(
     def drop_view(
         self,
         name: str,
+        /,
         *,
         schema: str | None = None,
         database: str | None = None,