% for import_ in imports:
${import_}
% endfor

async def ${function_name}(connection: Connection, timeout: timedelta | None = None) -> str:
    query = """
    ${query}
"""
    return await connection.execute(query, timeout=timeout.total_seconds() if timeout is not None else None)
