昺h !vddlmZmZmZmZmZddlmZddlm Z m Z ddl m Z erddl mZGdde ZdS) ) TYPE_CHECKINGAnyCallableDictOptional)Document) BaseModelroot_validator)get_from_dict_or_envApifyDatasetLoaderceZdZUdZeed<eed<ededefdZddddd e d ed e ege fd e e d e e de e ddfdZddddd e d ed e ege fd e e d e e de e ddfdZddddde ded e ege fd e e d e e de e ddfdZddddde ded e ege fd e e d e e de e ddfdZdS) 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_asyncvaluesreturnct|dd} ddlm}m}|||d<|||d<n#t$rt dwxYw|S)zValidate environment. Validate that an Apify API token is set and the apify-client Python package exists in the current environment. apify_api_tokenAPIFY_API_TOKENr) ApifyClientApifyClientAsyncrrz`Could not import apify-client Python package. Please install it with `pip install apify-client`.)r rrr ImportError)clsrrrrs k/var/www/html/services/rag-service/venv/lib/python3.11/site-packages/langchain_community/utilities/apify.pyvalidate_environmentz!ApifyWrapper.validate_environments / %'8    B B B B B B B B%0[%A%AF> "+;+;O+L+LF' ( (   E    s $8AN)build memory_mbytes timeout_secsactor_id run_inputdataset_mapping_functionrrrr cddlm}|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!rrrdefaultDatasetId dataset_idr")$langchain_community.document_loadersr ractorcall selfr r!r"rrrr actor_calls r call_actorzApifyWrapper.call_actor,sv4 LKKKKK&,,X66;;'% <  "!!"45%=    cKddlm}|j|||||d{V}||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$Nr%r&)r(r rr)r*r+s r acall_actorzApifyWrapper.acall_actorTs4 LKKKKK288BBGG'% H        "!!"45%=    r/task_id task_inputcddlm}|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 r3rrrr%r&)r(r rtaskr* r,r2r3r"rrrr task_calls rcall_actor_taskzApifyWrapper.call_actor_task|sv6 LKKKKK%**73388!'% 9  "! !34%=    r/cKddlm}|j|||||d{V}||d|S)r5rr r6Nr%r&)r(r rr7r*r8s racall_actor_taskzApifyWrapper.acall_actor_tasks6 LKKKKK166w??DD!'% E        "! !34%=    r/)__name__ __module__ __qualname____doc__r__annotations__r rrstrrrrintr.r1r:r<r/rrr s ^$48 $'+&*& & & & & #+D68+;"< & } &  }& sm&  & & & & \ $'+&*& & & & & #+D68+;"< & } &  }& sm&  & & & & \ $'+&*' ' ' ' ' #+D68+;"< ' } '  }' sm'  ' ' ' ' ^ $'+&*' ' ' ' ' #+D68+;"< ' } '  }' sm'  ' ' ' ' ' ' r/rN)typingrrrrrlangchain_core.documentsrlangchain_core.pydantic_v1r r langchain_core.utilsr r(r rrDr/rrIs??????????????------@@@@@@@@555555HGGGGGGA A A A A 9A A A A A r/