mirror of https://github.com/citusdata/citus.git
parent
8ef24f7e4d
commit
bced0cf1c2
|
@ -1,6 +1,7 @@
|
||||||
import psycopg
|
import psycopg
|
||||||
import pytest
|
import pytest
|
||||||
|
|
||||||
|
|
||||||
def test_call_param(cluster):
|
def test_call_param(cluster):
|
||||||
# create a distributed table and an associated distributed procedure
|
# create a distributed table and an associated distributed procedure
|
||||||
# to ensure parameterized CALL succeed, even when the param is the
|
# to ensure parameterized CALL succeed, even when the param is the
|
||||||
|
@ -21,7 +22,9 @@ def test_call_param(cluster):
|
||||||
coord.sql_prepared(sql, (1,))
|
coord.sql_prepared(sql, (1,))
|
||||||
|
|
||||||
coord.sql("SELECT create_distributed_table('test', 'i')")
|
coord.sql("SELECT create_distributed_table('test', 'i')")
|
||||||
coord.sql("SELECT create_distributed_function('p(int)', distribution_arg_name := '_i', colocate_with := 'test')")
|
coord.sql(
|
||||||
|
"SELECT create_distributed_function('p(int)', distribution_arg_name := '_i', colocate_with := 'test')"
|
||||||
|
)
|
||||||
|
|
||||||
# prepare/exec after distribution
|
# prepare/exec after distribution
|
||||||
coord.sql_prepared(sql, (2,))
|
coord.sql_prepared(sql, (2,))
|
||||||
|
|
Loading…
Reference in New Issue