(conn: psycopg.Connection[Any])
| 41 | |
| 42 | |
| 43 | def test_pipeline_status(conn: psycopg.Connection[Any]) -> None: |
| 44 | assert conn._pipeline is None |
| 45 | with conn.pipeline() as p: |
| 46 | assert conn._pipeline is p |
| 47 | assert p.status == pq.PipelineStatus.ON |
| 48 | assert p.status == pq.PipelineStatus.OFF |
| 49 | assert not conn._pipeline |
| 50 | |
| 51 | |
| 52 | def test_pipeline_reenter(conn: psycopg.Connection[Any]) -> None: |