From 875d03a900d054acaafe62bd0e0a4daab8c94f5a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kriszti=C3=A1n=20Sz=C5=B1cs?= Date: Mon, 5 Feb 2024 23:00:08 +0100 Subject: [PATCH] chore: update gen_matrix.py script --- gen_matrix.py | 8 +------- ibis/backends/flink/__init__.py | 4 ++-- 2 files changed, 3 insertions(+), 9 deletions(-) diff --git a/gen_matrix.py b/gen_matrix.py index e6c21381dd7e..9f9745cb7239 100644 --- a/gen_matrix.py +++ b/gen_matrix.py @@ -26,13 +26,7 @@ def get_leaf_classes(op): def main(): - internal_ops = { - # Never translates into anything - ops.UnresolvedExistsSubquery, - ops.ScalarParameter, - } - - public_ops = frozenset(get_leaf_classes(ops.Value)) - internal_ops + public_ops = frozenset(get_leaf_classes(ops.Value)) support = {"operation": [f"{op.__module__}.{op.__name__}" for op in public_ops]} support.update( (name, list(map(backend.has_operation, public_ops))) diff --git a/ibis/backends/flink/__init__.py b/ibis/backends/flink/__init__.py index 52febaf80e3a..2ae904f505ba 100644 --- a/ibis/backends/flink/__init__.py +++ b/ibis/backends/flink/__init__.py @@ -11,7 +11,7 @@ import ibis.expr.operations as ops import ibis.expr.schema as sch import ibis.expr.types as ir -from ibis.backends.base import BaseBackend, CanCreateDatabase +from ibis.backends.base import BaseBackend, CanCreateDatabase, NoUrl from ibis.backends.base.sql.ddl import fully_qualified_re, is_fully_qualified from ibis.backends.flink.compiler.core import FlinkCompiler from ibis.backends.flink.ddl import ( @@ -38,7 +38,7 @@ from ibis.api import Watermark -class Backend(BaseBackend, CanCreateDatabase): +class Backend(BaseBackend, CanCreateDatabase, NoUrl): name = "flink" compiler = FlinkCompiler supports_temporary_tables = True