diff options
author | Mike Bayer <mike_mp@zzzcomputing.com> | 2017-08-21 17:55:26 -0400 |
---|---|---|
committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2017-08-21 17:55:26 -0400 |
commit | ddefe6cf8c84a91c089100d34478b6346ed115ea (patch) | |
tree | 22a0ab7923b86eb63738632fab65d3b86e648345 /lib/sqlalchemy/testing | |
parent | a61ff195b5687b32828e1bc4d958c5cd87e94ff0 (diff) | |
download | sqlalchemy-ddefe6cf8c84a91c089100d34478b6346ed115ea.tar.gz |
- try to get PG database create to be more reliable
Change-Id: I9c9d101547f4484af447db924dc06afd0392a03e
Diffstat (limited to 'lib/sqlalchemy/testing')
-rw-r--r-- | lib/sqlalchemy/testing/provision.py | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/lib/sqlalchemy/testing/provision.py b/lib/sqlalchemy/testing/provision.py index ae82a2e89..7ea6a569c 100644 --- a/lib/sqlalchemy/testing/provision.py +++ b/lib/sqlalchemy/testing/provision.py @@ -167,7 +167,7 @@ def _pg_create_db(cfg, eng, ident): except Exception: pass currentdb = conn.scalar("select current_database()") - for attempt in range(3): + for attempt in range(10): try: conn.execute( "CREATE DATABASE %s TEMPLATE %s" % (ident, currentdb)) @@ -178,6 +178,15 @@ def _pg_create_db(cfg, eng, ident): else: raise else: + time.sleep(.5) + result = conn.execute( + "SELECT datname FROM pg_database " + "where datname=%s" % ident) + row = result.first() + if not row: + raise Exception( + "Database named %s did not get " + "created, in engine %r" % (ident, eng.url)) break |