Update isolation tests

src/test/regress/spec/isolation_blocking_shard_split.spec

@@ -4,6 +4,13 @@ setup
 	SET citus.shard_replication_factor to 1;
     SELECT setval('pg_dist_shardid_seq', 1500000);
 
+	-- Cleanup any orphan shards that might be left over from a previous run.
+	CREATE OR REPLACE FUNCTION run_try_drop_marked_shards()
+	RETURNS VOID
+	AS 'citus'
+	LANGUAGE C STRICT VOLATILE;
+	SELECT run_try_drop_marked_shards();
+
 	CREATE TABLE to_split_table (id int, value int);
 	SELECT create_distributed_table('to_split_table', 'id');
 }

src/test/regress/spec/isolation_blocking_shard_split_with_fkey_to_reference.spec

@@ -4,6 +4,13 @@ setup
     SET citus.shard_count to 2;
 	SET citus.shard_replication_factor to 1;
 
+	-- Cleanup any orphan shards that might be left over from a previous run.
+	CREATE OR REPLACE FUNCTION run_try_drop_marked_shards()
+	RETURNS VOID
+	AS 'citus'
+	LANGUAGE C STRICT VOLATILE;
+	SELECT run_try_drop_marked_shards();
+
 	CREATE TABLE reference_table (id int PRIMARY KEY, value int);
 	SELECT create_reference_table('reference_table');
 

src/test/regress/spec/isolation_non_blocking_shard_split.spec

@@ -10,6 +10,13 @@ setup
 	SET citus.shard_replication_factor to 1;
     SELECT setval('pg_dist_shardid_seq', 1500000);
 
+	-- Cleanup any orphan shards that might be left over from a previous run.
+	CREATE OR REPLACE FUNCTION run_try_drop_marked_shards()
+	RETURNS VOID
+	AS 'citus'
+	LANGUAGE C STRICT VOLATILE;
+	SELECT run_try_drop_marked_shards();
+
 	CREATE TABLE to_split_table (id int PRIMARY KEY, value int);
 	SELECT create_distributed_table('to_split_table', 'id');
 }

src/test/regress/spec/isolation_non_blocking_shard_split_fkey.spec

@@ -10,6 +10,13 @@ setup
     SET citus.shard_count to 2;
 	SET citus.shard_replication_factor to 1;
 
+	-- Cleanup any orphan shards that might be left over from a previous run.
+	CREATE OR REPLACE FUNCTION run_try_drop_marked_shards()
+	RETURNS VOID
+	AS 'citus'
+	LANGUAGE C STRICT VOLATILE;
+	SELECT run_try_drop_marked_shards();
+
 	CREATE TABLE reference_table (id int PRIMARY KEY, value int);
 	SELECT create_reference_table('reference_table');
 

src/test/regress/spec/isolation_non_blocking_shard_split_with_index_as_replicaIdentity.spec

@@ -9,6 +9,13 @@ setup
 	SET citus.shard_replication_factor to 1;
     SELECT setval('pg_dist_shardid_seq', 1500000);
 
+	-- Cleanup any orphan shards that might be left over from a previous run.
+	CREATE OR REPLACE FUNCTION run_try_drop_marked_shards()
+	RETURNS VOID
+	AS 'citus'
+	LANGUAGE C STRICT VOLATILE;
+	SELECT run_try_drop_marked_shards();
+
 	CREATE TABLE to_split_table (id int NOT NULL, value int);
 	CREATE UNIQUE INDEX split_table_index ON to_split_table(id);
 	ALTER TABLE to_split_table REPLICA IDENTITY USING INDEX split_table_index;