Ig"nddlmZmZmZmZmZddlmZddlm Z ddl m Z m Z erddl mZGdde Zy) ) TYPE_CHECKINGAnyCallableDictOptional)Document)get_from_dict_or_env) BaseModelmodel_validatorApifyDatasetLoaderceZdZUdZeed<eed<dZeeed<e de de d efd Z dddd d ed e de e gefdeedeedeed dfdZdddd d ed e de e gefdeedeedeed dfdZdddd dede de e gefdeedeedeed dfdZdddd dede de e gefdeedeedeed dfdZy) ApifyWrapperzWrapper around Apify. To use, you should have the ``apify-client`` python package installed, and the environment variable ``APIFY_API_TOKEN`` set with your API key, or pass `apify_api_token` as a named parameter to the constructor. apify_clientapify_client_asyncNapify_api_tokenbefore)modevaluesreturncRt|dd} ddlm}m}||}t |j dx}r|j dxxdz cc<||}t |j dx}r|j dxxdz cc<||d <||d <|S#t$r td wxYw) zValidate environment. Validate that an Apify API token is set and the apify-client Python package exists in the current environment. rAPIFY_API_TOKENr) ApifyClientApifyClientAsync httpx_clientz user-agentz; Origin/langchainhttpx_async_clientrrz`Could not import apify-client Python package. Please install it with `pip install apify-client`.)r rrrgetattr http_clientheaders ImportError) clsrrrrclientr async_clientrs `/var/www/html/answerous/venv/lib/python3.12/site-packages/langchain_community/utilities/apify.pyvalidate_environmentz!ApifyWrapper.validate_environments/ %'8   B 1F&v'9'9>JJ|J$$\26JJ2+O&!#**<8 "+7F' (  E  s BBB&)build memory_mbytes timeout_secsactor_id run_inputdataset_mapping_functionr&r'r(r cddlm}|jj|j ||||}||d|S)aRun an Actor on the Apify platform and wait for results to be ready. Args: actor_id (str): The ID or name of the Actor on the Apify platform. run_input (Dict): The input object of the Actor that you're trying to run. dataset_mapping_function (Callable): A function that takes a single dictionary (an Apify dataset item) and converts it to an instance of the Document class. build (str, optional): Optionally specifies the actor build to run. It can be either a build tag or build number. memory_mbytes (int, optional): Optional memory limit for the run, in megabytes. timeout_secs (int, optional): Optional timeout for the run, in seconds. Returns: ApifyDatasetLoader: A loader that will fetch the records from the Actor run's default dataset. rr r*r&r'r(defaultDatasetId dataset_idr+)$langchain_community.document_loadersr ractorcall selfr)r*r+r&r'r(r actor_calls r$ call_actorzApifyWrapper.call_actor8sU4 L&&,,X6;;'% < "!"45%=  cKddlm}|jj|j ||||d{}||d|S7w)aRun an Actor on the Apify platform and wait for results to be ready. Args: actor_id (str): The ID or name of the Actor on the Apify platform. run_input (Dict): The input object of the Actor that you're trying to run. dataset_mapping_function (Callable): A function that takes a single dictionary (an Apify dataset item) and converts it to an instance of the Document class. build (str, optional): Optionally specifies the actor build to run. It can be either a build tag or build number. memory_mbytes (int, optional): Optional memory limit for the run, in megabytes. timeout_secs (int, optional): Optional timeout for the run, in seconds. Returns: ApifyDatasetLoader: A loader that will fetch the records from the Actor run's default dataset. rr r-Nr.r/)r1r rr2r3r4s r$ acall_actorzApifyWrapper.acall_actor`sd4 L2288BGG'% H  "!"45%=   8AA Atask_id task_inputcddlm}|jj|j ||||}||d|S)Run a saved Actor task on Apify and wait for results to be ready. Args: task_id (str): The ID or name of the task on the Apify platform. task_input (Dict): The input object of the task that you're trying to run. Overrides the task's saved input. dataset_mapping_function (Callable): A function that takes a single dictionary (an Apify dataset item) and converts it to an instance of the Document class. build (str, optional): Optionally specifies the actor build to run. It can be either a build tag or build number. memory_mbytes (int, optional): Optional memory limit for the run, in megabytes. timeout_secs (int, optional): Optional timeout for the run, in seconds. Returns: ApifyDatasetLoader: A loader that will fetch the records from the task run's default dataset. rr r=r&r'r(r.r/)r1r rtaskr3 r5r<r=r+r&r'r(r task_calls r$call_actor_taskzApifyWrapper.call_actor_tasksU6 L%%**7388!'% 9 " !34%=  r8cKddlm}|jj|j ||||d{}||d|S7w)r?rr r@Nr.r/)r1r rrAr3rBs r$acall_actor_taskzApifyWrapper.acall_actor_tasksd6 L1166w?DD!'% E  " !34%=   r;)__name__ __module__ __qualname____doc__r__annotations__rrstrr classmethodrr%rrintr7r:rDrFr8r$rr s %)OXc])(#$3$L $'+&*& & & #+D68+;"< & } &  }& sm&  & \ $'+&*& & & #+D68+;"< & } &  }& sm&  & \ $'+&*' ' ' #+D68+;"< ' } '  }' sm'  ' ^ $'+&*' ' ' #+D68+;"< ' } '  }' sm'  ' r8rN)typingrrrrrlangchain_core.documentsrlangchain_core.utilsr pydanticr r r1r rrOr8r$rTs(??-5/GM 9M r8