From cbb7cff30a20ca6591e83057e14744722b0e82e5 Mon Sep 17 00:00:00 2001 From: Ahmet Gedemenli Date: Mon, 12 Sep 2022 12:44:54 +0300 Subject: [PATCH] test --- src/test/regress/sql/failure_online_move_shard_placement.sql | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/test/regress/sql/failure_online_move_shard_placement.sql b/src/test/regress/sql/failure_online_move_shard_placement.sql index f189a805d..01339c7c7 100644 --- a/src/test/regress/sql/failure_online_move_shard_placement.sql +++ b/src/test/regress/sql/failure_online_move_shard_placement.sql @@ -90,7 +90,9 @@ SELECT citus.mitmproxy('conn.onQuery(query="^ALTER SUBSCRIPTION .* DISABLE").can SELECT master_move_shard_placement(101, 'localhost', :worker_1_port, 'localhost', :worker_2_proxy_port); -- failure on dropping subscription -SELECT citus.mitmproxy('conn.onQuery(query="ENABLE SUBSCRIPTION|DROP SUBSCRIPTION").kill()'); +SELECT citus.mitmproxy('conn.onQuery(query="^ALTER SUBSCRIPTION").after(2).kill()'); +SELECT master_move_shard_placement(101, 'localhost', :worker_1_port, 'localhost', :worker_2_proxy_port); +SELECT citus.mitmproxy('conn.onQuery(query="nonexistingquery").kill()'); SELECT master_move_shard_placement(101, 'localhost', :worker_1_port, 'localhost', :worker_2_proxy_port); -- cancellation on dropping subscription