(self)
| 221 | ) |
| 222 | |
| 223 | async def test_copy_from_query_to_bad_output(self): |
| 224 | with self.assertRaisesRegex(TypeError, 'output is expected to be'): |
| 225 | await self.con.copy_from_query(''' |
| 226 | SELECT |
| 227 | i, i * 10 |
| 228 | FROM |
| 229 | generate_series(1, 5) AS i |
| 230 | WHERE |
| 231 | i = $1 |
| 232 | ''', 3, output=1) |
| 233 | |
| 234 | async def test_copy_from_query_to_sink(self): |
| 235 | with tempfile.NamedTemporaryFile() as f: |
nothing calls this directly
no test coverage detected