SjbddlmZmZmZmZmZmZddlZddlm Z m Z ddl m Z ddl mZddddddddeeed ed eed eed eed eedeeddeeee fdeeeffdZdeeefdeeeffdZdddddddde deeed ed eed eed eed eedeeddeeee fde fdZde dede fdZdddde dededeede f dZdddddddddde deeed ed eed eededeed eed eedeeddeeee fde fdZde dedefd Zy)!)AnyDictListLiteralOptionalUnionN) AgentResponseAgentWebhookConfig)AsyncHttpClient)_normalize_schema)schema integration max_creditsstrict_constrain_to_urlsmodelwebhookurlspromptrrrrr)z spark-1-proz spark-1-minirreturnci}|||d<||d<|5t|} | | |d<n"tdt|jd|5t |j rt |j |d<| |dkDr||d<||r||d <|||d <|,t |tr||d <|S|jd |d <|S)NrrrzInvalid schema type: zN. Schema must be a dict, Pydantic BaseModel class, or Pydantic model instance.rr maxCreditsstrictConstrainToURLsrrT) exclude_none)r ValueErrortype__name__strstrip isinstance model_dump) rrrrrrrrbodynormalized_schemas Q/root/.hermes/venv/lib/python3.12/site-packages/firecrawl/v2/methods/aio/agent.py_prepare_agent_requestr% sD V DN -f5  (.DN'V (=(='>?__ 3{#3#9#9#;!+.446];?(\+0H(@ $% W  gs #%DO K&00d0CDO Kpayloadc\t|}d|vr d|vr|d|d<d|vr d|vr|d|d<|S)N expiresAt expires_at creditsUsed credits_used)dict)r'outs r$!_normalize_agent_response_payloadr/1sL w-Ccl#5 ,Lc 9!-0N Jr&clientc Kt||||||||} |jd| d{} t| j} t di| S7(w)Nrrrrrrrz /v2/agent)r%postr/jsonr ) r0rrrrrrrrr"respr's r$ start_agentr7:sb " !9 D[$/ /D/ )r7getattrrM) r0rrrrr?r@rrrrstartedr8s r$agentrRlsk  !9  GWdD )F FF-QXY YY  Zs!A A'A A A  A cK|jd|d{}|jjddS7$w)a Cancel a running agent job. Args: client: Async HTTP client instance job_id: ID of the agent job to cancel Returns: bool: True if the agent was cancelled, False otherwise Raises: Exception: If the cancellation fails r:NsuccessF)deleter5r;)r0r8r6s r$ cancel_agentrVs<F845 5D 99;??9e ,, 6sA?%A)typingrrrrrrrFtypesr r utils.http_client_asyncr utils.validationr rintboolr%r/r7r<rMrRrVr3r&r$r]s<<661!!%!%/3>B8<% 49 % % SM % # % # %'tn% G9: ;%eC!334 5% #s(^%PtCH~$sCx.!!%!%/3>B8<$ $ 49 $  $ SM $ # $#$'tn$ G9: ;$eC!334 5$$6$?$C$M$! 3 3 3 3 c] 3  3,!!%!!%/3>B8<Z Z 49 Z  Z SM Z # ZZc]Z#Z'tnZ G9: ;ZeC!334 5ZZ>----r&