Кравлер на python останавливаеться

async def get_page(url, semaphore, n = 1):
    async with semaphore:
        ua = UserAgent()
        async with aiohttp.ClientSession() as session:
            async with session.get(url, headers={"user-agent": ua.chrome}, timeout=aiohttp.ClientTimeout(10)) as response:
                try:
                    html = await response.text()
                    l = crawl(html, f"{url.split('//', 1)[0]}//{urlparse(url).netloc}") # get all links on page
                    #print(l)
                    unique = [i["id"] for i in await get_uniques(l.urls)] # weed out links that are already in the database
                    #print(unique)
                    await add_page(url, html) # add current page to the database
                    if n+1 <= 3: # if depth is not maximum
                        tasks = [get_page(i, semaphore, n+1) for i in unique] # making the same for each link on current page
                        await asyncio.gather(*tasks)
 
                except UnicodeDecodeError as e:
                    print(e)
async def main():
    print("start")
    sema = asyncio.Semaphore(3)
    start_url = 'fist url'
    await get_page(start_url, sema)
 
if __name__ == "__main__":
    asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
    asyncio.run(main())

async def add_page(link, content):
    """add page to the database"""
    con = await asyncpg.connect(user=user, password=password, database=database, host=host, timeout=10)
    try:
        await con.execute(
            'INSERT INTO indexed_pages ("link", "content") VALUES ($1, $2)',
            link, content
        )
        print("added")
    except asyncpg.exceptions.UniqueViolationError:
        print(f"Page with link {link} is already exists")
    finally:
        await con.close()
 
async def get_uniques(array: list):
    """get array of links that are not in the database"""
    con = await asyncpg.connect(user=user, password=password, database=database, host=host, timeout=10)
    try:
        return await con.fetch(
            """select *
from unnest($1::text[]) as t(id)
except
select id
from (select link from indexed_pages) as the_table(id)""", array
        )
    finally:
        await con.close()