Skip to content

Commit 768ae81

Browse files
authored
ref: create common ancestor for custom ops (#1338)
1 parent c21448a commit 768ae81

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

python/xorq/expr/relations.py

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,11 @@ def __dask_tokenize__(self):
137137
)
138138

139139

140-
class CachedNode(ops.DatabaseTable):
140+
class DatabaseTableView(ops.DatabaseTable):
141+
pass
142+
143+
144+
class CachedNode(DatabaseTableView):
141145
parent: Any = None
142146
storage: Any = None
143147

@@ -150,7 +154,7 @@ class CachedNode(ops.DatabaseTable):
150154
)
151155

152156

153-
class RemoteTable(ops.DatabaseTable):
157+
class RemoteTable(DatabaseTableView):
154158
remote_expr: Expr = None
155159

156160
@classmethod
@@ -168,7 +172,7 @@ def into_backend(expr, con, name=None):
168172
return RemoteTable.from_expr(con=con, expr=expr, name=name).to_expr()
169173

170174

171-
class FlightExpr(ops.DatabaseTable):
175+
class FlightExpr(DatabaseTableView):
172176
input_expr: Expr = None
173177
unbound_expr: Expr = None
174178
make_server: Callable = None
@@ -314,7 +318,7 @@ def flight_expr(
314318
)
315319

316320

317-
class FlightUDXF(ops.DatabaseTable):
321+
class FlightUDXF(DatabaseTableView):
318322
input_expr: Expr = None
319323
# FIXME: fix circular import issue so we can possibly pass an instance of AbstractExchanger
320324
udxf: type = None

0 commit comments

Comments
 (0)