From 8f86e85c505bfa1d2a515349aae0804bbe7f9de3 Mon Sep 17 00:00:00 2001 From: tpv Date: Tue, 30 Jun 2026 12:55:20 -0700 Subject: [PATCH] added proxy managament from dsqls module --- src/monitor_utils/runner.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/monitor_utils/runner.py b/src/monitor_utils/runner.py index e8e406b..70f72de 100644 --- a/src/monitor_utils/runner.py +++ b/src/monitor_utils/runner.py @@ -4,6 +4,7 @@ from datetime import datetime, timedelta, timezone from typing import Awaitable, Callable, Iterable import aiohttp +from aioproxies import AioProxies from curl_cffi.requests import AsyncSession from motor.motor_asyncio import AsyncIOMotorCollection @@ -134,6 +135,7 @@ def build_product_details( async def execute_monitor_logic( + proxies: AioProxies, category_identifiers: list[str] | dict[str, str], task_func: Callable[..., Awaitable[None]], headers: dict | None = None, @@ -144,9 +146,12 @@ async def execute_monitor_logic( ): while True: session_ctx = ( - get_tls_session(headers=headers) + get_tls_session( + headers=headers, + proxies=proxies, + ) if use_tls - else get_base_session(headers=headers, cookies=cookies) + else get_base_session(headers=headers, cookies=cookies, proxies=proxies) ) async with session_ctx as session: LOGGER.info("Starting tasks...")