Skip to content

Commit 778ea46

Browse files
committed
refactor(risingwave)!: canonicalize signatures of risingwave-specific create_* methods
1 parent f5a4c79 commit 778ea46

File tree

1 file changed

+8
-7
lines changed

1 file changed

+8
-7
lines changed

ibis/backends/risingwave/__init__.py

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -686,6 +686,7 @@ def list_databases(
686686
def create_materialized_view(
687687
self,
688688
name: str,
689+
/,
689690
obj: ir.Table,
690691
*,
691692
database: str | None = None,
@@ -738,6 +739,7 @@ def create_materialized_view(
738739
def drop_materialized_view(
739740
self,
740741
name: str,
742+
/,
741743
*,
742744
database: str | None = None,
743745
force: bool = False,
@@ -764,8 +766,9 @@ def drop_materialized_view(
764766
def create_source(
765767
self,
766768
name: str,
767-
schema: ibis.Schema,
769+
/,
768770
*,
771+
schema: ibis.Schema,
769772
database: str | None = None,
770773
connector_properties: dict,
771774
data_format: str,
@@ -818,11 +821,7 @@ def create_source(
818821
return self.table(name, database=database)
819822

820823
def drop_source(
821-
self,
822-
name: str,
823-
*,
824-
database: str | None = None,
825-
force: bool = False,
824+
self, name: str, /, *, database: str | None = None, force: bool = False
826825
) -> None:
827826
"""Drop a Source.
828827
@@ -846,9 +845,10 @@ def drop_source(
846845
def create_sink(
847846
self,
848847
name: str,
848+
/,
849+
*,
849850
sink_from: str | None = None,
850851
connector_properties: dict | None = None,
851-
*,
852852
obj: ir.Table | None = None,
853853
database: str | None = None,
854854
data_format: str | None = None,
@@ -909,6 +909,7 @@ def create_sink(
909909
def drop_sink(
910910
self,
911911
name: str,
912+
/,
912913
*,
913914
database: str | None = None,
914915
force: bool = False,

0 commit comments

Comments
 (0)