openstack/taskflow
Code Issues Proposed changes

Fix skipped database persistence tests

Browse Source 
Change-Id: I786465ba28e9df9b4c1b2c1abbb163cbed15d8a2
This commit is contained in:
Takashi Kajinami
2025-05-27 20:47:06 +09:00
parent d9f26c51b9
commit c7aac5b751
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
taskflow/tests/unit/persistence/test_sql_persistence.py
View File

@@ -173,7 +173,7 @@ class MysqlPersistenceTest(BackendPersistenceTestMixin, test.TestCase):
db_uri = _get_connect_string('mysql', USER, PASSWD)
engine = sa.create_engine(db_uri)
with contextlib.closing(engine.connect()) as conn:
conn.execute("CREATE DATABASE %s" % DATABASE)
conn.execute(sa.text("CREATE DATABASE %s" % DATABASE))
except Exception as e:
raise Exception('Failed to initialize MySQL db: %s' % (e))
finally:
@@ -190,7 +190,7 @@ class MysqlPersistenceTest(BackendPersistenceTestMixin, test.TestCase):
try:
engine = sa.create_engine(self.db_uri)
with contextlib.closing(engine.connect()) as conn:
conn.execute("DROP DATABASE IF EXISTS %s" % DATABASE)
conn.execute(sa.text("DROP DATABASE IF EXISTS %s" % DATABASE))
except Exception as e:
raise Exception('Failed to remove temporary database: %s' % (e))
finally:
@@ -215,7 +215,7 @@ class PostgresPersistenceTest(BackendPersistenceTestMixin, test.TestCase):
engine = sa.create_engine(db_uri)
with contextlib.closing(engine.connect()) as conn:
conn.connection.set_isolation_level(0)
conn.execute("CREATE DATABASE %s" % DATABASE)
conn.execute(sa.text("CREATE DATABASE %s" % DATABASE))
conn.connection.set_isolation_level(1)
except Exception as e:
raise Exception('Failed to initialize PostgreSQL db: %s' % (e))
@@ -239,7 +239,7 @@ class PostgresPersistenceTest(BackendPersistenceTestMixin, test.TestCase):
engine = sa.create_engine(db_uri)
with contextlib.closing(engine.connect()) as conn:
conn.connection.set_isolation_level(0)
conn.execute("DROP DATABASE IF EXISTS %s" % DATABASE)
conn.execute(sa.text("DROP DATABASE IF EXISTS %s" % DATABASE))
conn.connection.set_isolation_level(1)
except Exception as e:
raise Exception('Failed to remove temporary database: %s' % (e))