From 543efe00775e4d127d3bc5aa620f837ef7b65bc3 Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Wed, 18 May 2022 21:38:31 -0400 Subject: [PATCH] Add parameterized queued write test --- system_test/full_system_test.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/system_test/full_system_test.py b/system_test/full_system_test.py index 14c3de57..6907ae30 100644 --- a/system_test/full_system_test.py +++ b/system_test/full_system_test.py @@ -1186,15 +1186,18 @@ class TestRequestForwarding(unittest.TestCase): j = f.execute_queued('INSERT INTO foo(name) VALUES("declan")') self.assertEqual(j, d_("{'results': []}")) + j = f.execute_queued('INSERT INTO foo(name) VALUES(?)', params=["aoife"]) + self.assertEqual(j, d_("{'results': []}")) + # Wait for queued write to happen. timeout = 10 t = 0 while True: j = l.query('SELECT * FROM foo') - if j == d_("{'results': [{'values': [[1, 'fiona'], [2, 'declan']], 'types': ['integer', 'text'], 'columns': ['id', 'name']}]}"): + if j == d_("{'results': [{'values': [[1, 'fiona'], [2, 'declan'], [3, 'aoife']], 'types': ['integer', 'text'], 'columns': ['id', 'name']}]}"): break if t > timeout: - raise Exception('timeout', nSnaps) + raise Exception('timeout') time.sleep(1) t+=1