Skip to content

Commit 3f5d090

Browse files
committed
fix(postgres): dedent in udfs
1 parent ffb23ec commit 3f5d090

File tree

2 files changed

+8
-10
lines changed

2 files changed

+8
-10
lines changed

ibis/backends/sql/compilers/postgres.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -161,13 +161,13 @@ def _compile_python_udf(self, udf_node: ops.ScalarUDF):
161161
type_mapper = self.type_mapper
162162
argnames = udf_node.argnames
163163
return """\
164-
CREATE OR REPLACE FUNCTION {ident}({signature})
165-
RETURNS {return_type}
166-
LANGUAGE {language}
167-
AS $$
168-
{source}
169-
return {name}({args})
170-
$$""".format(
164+
CREATE OR REPLACE FUNCTION {ident}({signature})
165+
RETURNS {return_type}
166+
LANGUAGE {language}
167+
AS $$
168+
{source}
169+
return {name}({args})
170+
$$""".format(
171171
name=type(udf_node).__name__,
172172
ident=self.__sql_name__(udf_node),
173173
signature=", ".join(

ibis/backends/tests/test_impure.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -99,9 +99,7 @@ def my_random(x: float) -> float:
9999
lambda table: my_random(table.float_col),
100100
marks=[
101101
*no_udfs,
102-
pytest.mark.notyet(
103-
["flink", "postgres"], reason="instances are uncorrelated"
104-
),
102+
pytest.mark.notyet(["flink"], reason="instances are uncorrelated"),
105103
],
106104
id="udf",
107105
),

0 commit comments

Comments
 (0)