dhw$SSKJrJrJrJrJr SSKJr SSKJ r SSK J r SSK J r Jr \(aSSKJr \"SSS S 9"S S \ 55rg )) TYPE_CHECKINGAnyCallableDictOptional) deprecated)Document)get_from_dict_or_env) BaseModelmodel_validatorApifyDatasetLoaderz0.3.18zThis class is deprecated and will be removed in a future version. You can swap to using the `ApifyWrapper` implementation in `langchain_apify` package. See zlangchain_apify.ApifyWrapper)sincemessagealternative_importc\rSrSr%Sr\\S'\\S'Sr\\ \S'\ "SS9\ S \ S \4S j55r SSSS .S \ S\ S\\ /\4S\\ S\\S\\S S4SjjrSSSS .S \ S\ S\\ /\4S\\ S\\S\\S S4SjjrSSSS .S\ S\ S\\ /\4S\\ S\\S\\S S4SjjrSSSS .S\ S\ S\\ /\4S\\ S\\S\\S S4SjjrSrg) ApifyWrapper zWrapper 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)modevaluesreturncd[USS5nSSKJnJn U"U5n[ UR S5=n(aUR S==S- ss'U"U5n[ UR S5=n(aUR S==S- ss'XQS 'XqS 'U$![a [S 5ef=f) 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_clientr!s [/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/utilities/apify.pyvalidate_environment!ApifyWrapper.validate_environment!s/ %'8   B 1F&v'9'9>JJ|J$$\26JJ2+O&!#**<8 "+7' (  E  s BBB/)build memory_mbytes timeout_secsactor_id run_inputdataset_mapping_functionr,r-r.rcxSSKJn URRU5R UUUUS9nU"USUS9$)a,Run 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 r0r,r-r.defaultDatasetId dataset_idr1)$langchain_community.document_loadersrractorcall selfr/r0r1r,r-r.r actor_calls r) call_actorApifyWrapper.call_actorCsU4 L&&,,X6;;'% < "!"45%=  c# SSKJn URRU5R UUUUS9IShvN nU"USUS9$N7f)a,Run 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 r3Nr4r5)r7rrr8r9r:s r) acall_actorApifyWrapper.acall_actorksc4 L2288BGG'% H  "!"45%=   5AAAtask_id task_inputcxSSKJn URRU5R UUUUS9nU"USUS9$)PRun 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 rEr,r-r.r4r5)r7rrtaskr9 r;rDrEr1r,r-r.r task_calls r)call_actor_taskApifyWrapper.call_actor_tasksU6 L%%**7388!'% 9 " !34%=  r?c# SSKJn URRU5R UUUUS9IShvN nU"USUS9$N7f)rGrr rHNr4r5)r7rrrIr9rJs r)acall_actor_taskApifyWrapper.acall_actor_tasksc6 L1166w?DD!'% E  " !34%=   rC)__name__ __module__ __qualname____firstlineno____doc__r__annotations__rrstrr classmethodrr*rr intr=rArLrO__static_attributes__rQr?r)rr s  %)OXc])(#$3$L $'+&*& & & #+D68+;"< & } &  }& sm&  & \ $'+&*& & & #+D68+;"< & } &  }& sm&  & \ $'+&*' ' ' #+D68+;"< ' } '  }' sm'  ' ^ $'+&*' ' ' #+D68+;"< ' } '  }' sm'  ' ' r?rN)typingrrrrrlangchain_core._apirlangchain_core.documentsr langchain_core.utilsr pydanticr r r7rrrQr?r)rasM??*-5/G  9 6 M 9M  M r?