Function executescript

tests/test_async_read_write_cancellation.py:395–398

(real_connection: sqlite3.Connection, statement: str)

    execute_started: asyncio.Event,
) -> None:
    def executescript(real_connection: sqlite3.Connection, statement: str) -> sqlite3.Cursor:
        if "PRAGMA journal_mode" in statement:
            loop.call_soon_threadsafe(execute_started.set)
        return real_connection.executescript(statement)

    _patch_async_connection(mocker, executescript=executescript)