@@ -14,16 +14,27 @@ def __init__(self, model: BaseChatModel | None = None):
1414 else :
1515 self .model = model
1616
17- async def _run (self , url : str , elements : dict ) -> dict :
18- content = await fetch_page_content (url = url )
17+ async def _run (
18+ self , url : str , elements : dict , proxy_settings : dict | None = None
19+ ) -> dict :
20+ if proxy_settings :
21+ content = await fetch_page_content (url = url , proxy_settings = proxy_settings )
22+ else :
23+ content = await fetch_page_content (url = url )
1924 extractor = TabularExtractor (
2025 elements = elements , model = self .model , content = content
2126 )
2227 result = await extractor .run ()
2328 return result
2429
25- def run (self , url : str , elements : dict ) -> dict :
26- return asyncio .run (self ._run (url = url , elements = elements ))
30+ def run (self , url : str , elements : dict , proxy_settings : dict | None = None ) -> dict :
31+ return asyncio .run (
32+ self ._run (url = url , elements = elements , proxy_settings = proxy_settings )
33+ )
2734
28- async def arun (self , url : str , elements : dict ) -> dict :
29- return await self ._run (url = url , elements = elements )
35+ async def arun (
36+ self , url : str , elements : dict , proxy_settings : dict | None = None
37+ ) -> dict :
38+ return await self ._run (
39+ url = url , elements = elements , proxy_settings = proxy_settings
40+ )
0 commit comments