cmd_cleanup="psql -Atc \"select datname from pg_database where datname != \'template0\'\" | while read a; do echo \"check for ${a}\";psql -Atc \"select \'drop schema if exists \' || nspname || \' cascade;\' from (select nspname from pg_namespace where nspname like \'pg_temp%\' union select nspname from gp_dist_random(\'pg_namespace\') where nspname like \'pg_temp%\' except select \'pg_temp_\' || sess_id::varchar from pg_stat_activity) as foo\" ${a}; done"
res={'rc':0,'stderr':'','stdout':''}
run_shell_command(cmd_cleanup,'do_clean',res)
ifres['rc']>0:
raiseException("Failed to do cleanup %s"%res[stderr])