test_interval=int(math.ceil(detach_timeout*num_detachs))

insert_pgbench_script=os.path.dirname(os.path.realpath(__file__)) \

detach_pgbench_script=os.path.dirname(os.path.realpath(__file__)) \

self.assertTrue(os.path.isfile(insert_pgbench_script),

msg="pgbench script with insert timestamp doesn't exist")

self.assertTrue(os.path.isfile(detach_pgbench_script),

msg="pgbench script with detach letfmost partition doesn't exist")

node=self.start_new_pathman_cluster(allows_streaming=False)

FNULL=open(os.devnull,'w')

init_pgbench=node.pgbench(stdout=FNULL,stderr=FNULL,options=["-i"])

init_pgbench.wait()

inserts=node.pgbench(stdout=FNULL,stderr=subprocess.PIPE,options=[

"-j","%i"%num_insert_workers,

"-c","%i"%num_insert_workers,

"-f","pgbench_scripts/insert_current_timestamp.pgbench",

"-f",insert_pgbench_script,

"-T","%i"% (test_interval+inserts_advance)

])

time.sleep(inserts_advance)

detachs=node.pgbench(stdout=FNULL,stderr=subprocess.PIPE,options=[

"-D","timeout=%f"%detach_timeout,

"-f","pgbench_scripts/detachs_in_timeout.pgbench",

"-f",detach_pgbench_script,

"-T","%i"%test_interval

])

inserts_errors=inserts.stderr.read()

self.assertIsNone(

re.search("ERROR: constraint",inserts_errors),

msg="Race condition between detach and concurrent inserts with append partition is expired")

self.assertIsNone(re.search("ERROR|FATAL|PANIC",inserts_errors),

msg="Race condition between detach and concurrent inserts with append partition is expired")

node.stop()

select detach_range_partition(partition) from (select partition from pathman_partition_list where parent='ts_range_partitioned'::regclass order by range_min limit 1) t;

select pg_sleep(:timeout);

insert into ts_range_partitioned values (current_timestamp);