+
    }i                    Z   ^ RI Ht ^ RIHt ^ RIHtHtHtHt ^ RIH	t	H
t
HtHt ^ RIHt ^ RIHt ^ RIHt ^ RIHt ]! R	]R
7      t]! R4       ! R R]	4      4       t]! R4       ! R R]4      4       t]! R4       ! R R]4      4       t]! R4       ! R R]4      4       t]! R4       ! R R]	4      4       t]! R4       ! R R]]],          4      4       t]! R4       ! R R]	4      4       t]! R4       ! R R]	4      4       t]! R4       ! R R]	4      4       t]! R4       ! R R]	4      4       tR # )!    )annotations)datetime)TYPE_CHECKING	AnnotatedAnyGeneric)	BaseModelBeforeValidator
ConfigDictField)TypeVar)
HttpMethod)
docs_group)validate_http_urlKvsValueType)defaultzStorage datac                  n    ] tR t^t$ Rt]! RRRRR7      tR]R&    R]R&    R	]R
&    R]R&    R]R&   RtR# )StorageMetadatazuRepresents the base model for storage metadata.

It contains common fields shared across all specific storage types.
Tallow)validate_by_namevalidate_by_aliasextrafrom_attributesz!Annotated[str, Field(alias='id')]idz8Annotated[str | None, Field(alias='name', default=None)]namez.Annotated[datetime, Field(alias='accessedAt')]accessed_atz-Annotated[datetime, Field(alias='createdAt')]
created_atz.Annotated[datetime, Field(alias='modifiedAt')]modified_at N	__name__
__module____qualname____firstlineno____doc__r   model_config__annotations____static_attributes__r       p/Users/ahmad/.openclaw/workspace/my-crawler/.venv/lib/python3.14/site-packages/crawlee/storage_clients/models.pyr   r      sH    
 ttSZlpqL))/
BB"??;==5??;r)   r   c                  <    ] tR t^)t$ Rt]! RRRR7      tR]R&   RtR# )DatasetMetadatazModel for a dataset metadata.Tr   r   r   z(Annotated[int, Field(alias='itemCount')]
item_countr   Nr    r   r)   r*   r,   r,   )   s    'tt]abL88-r)   r,   c                  0    ] tR t^3tRt]! RRRR7      tRtR# )KeyValueStoreMetadataz%Model for a key-value store metadata.Tr-   r   N)r!   r"   r#   r$   r%   r   r&   r(   r   r)   r*   r0   r0   3   s    /tt]abLr)   r0   c                  `    ] tR t^:t$ Rt]! RRRR7      tR]R&    R]R&    R]R	&    R
]R&   RtR# )RequestQueueMetadataz#Model for a request queue metadata.Tr-   z2Annotated[bool, Field(alias='hadMultipleClients')]had_multiple_clientsz2Annotated[int, Field(alias='handledRequestCount')]handled_request_countz2Annotated[int, Field(alias='pendingRequestCount')]pending_request_countz0Annotated[int, Field(alias='totalRequestCount')]total_request_countr   Nr    r   r)   r*   r2   r2   :   s8    -tt]abLLLXMMGMMEIIIr)   r2   c                  X    ] tR t^Mt$ Rt]! RRRR7      tR]R&    R]R&    RtR	]R
&   Rt	R# )KeyValueStoreRecordMetadataz,Model for a key-value store record metadata.Tr-   z"Annotated[str, Field(alias='key')]keyz*Annotated[str, Field(alias='contentType')]content_typeNz8Annotated[int | None, Field(alias='size', default=None)]sizer   )
r!   r"   r#   r$   r%   r   r&   r'   r;   r(   r   r)   r*   r8   r8   M   s>    6tt]abL	++
 =<
 FJD
BI*r)   r8   c                  <    ] tR t^ct$ Rt]! RRRR7      tR]R&   RtR# )KeyValueStoreRecordz#Model for a key-value store record.Tr-   z-Annotated[KvsValueType, Field(alias='value')]valuer   Nr    r   r)   r*   r=   r=   c   s    -tt]abL88"r)   r=   c                     a  ] tR t^mt0 o $ Rt]! RRRR7      tR]R&    R]R&    R]R&    R]R&    R	]R
&    ]'       d   . t	R]R&   Rt
R# R]R&   Rt
R# )DatasetItemsListPagezPModel for a single page of dataset items returned from a collection list method.Tr-   z Annotated[int, Field(default=0)]countoffsetlimittotalz%Annotated[bool, Field(default=False)]descz
list[dict]itemsz2Annotated[list[dict], Field(default_factory=list)]r   N)r!   r"   r#   r$   r%   r   r&   r'   r   rF   r(   )__conditional_annotations__s   @r*   r@   r@   m   s_     Ztt]abL++6,,[++P++N
//@ z>AA>r)   r@   c                  `    ] tR t^t$ Rt]! RRRR7      tRtR]R&    R]R&   R	]R
&   R]R&   Rt	R# )ProcessedRequestzRepresents a processed request.Tr-   Nz=Annotated[str | None, Field(alias='requestId', default=None)]r   (Annotated[str, Field(alias='uniqueKey')]
unique_keyz1Annotated[bool, Field(alias='wasAlreadyPresent')]was_already_presentz1Annotated[bool, Field(alias='wasAlreadyHandled')]was_already_handledr   )
r!   r"   r#   r$   r%   r   r&   r   r'   r(   r   r)   r*   rI   rI      s4    )tt]abLHLBELa88JJJJr)   rI   c                  T    ] tR t^t$ Rt]! RRRR7      tR]R&   R]R&   RtR	]R
&   Rt	R# )UnprocessedRequestz"Represents an unprocessed request.Tr-   rJ   rK   z;Annotated[str, BeforeValidator(validate_http_url), Field()]urlNz%Annotated[HttpMethod | None, Field()]methodr   )
r!   r"   r#   r$   r%   r   r&   r'   rQ   r(   r   r)   r*   rO   rO      s+    ,tt]abL88	DD48F18r)   rO   c                  H    ] tR t^t$ Rt]! RRRR7      tR]R&    R]R&   RtR	# )
AddRequestsResponsea  Model for a response to add requests to a queue.

Contains detailed information about the processing results when adding multiple requests
to a queue. This includes which requests were successfully processed and which ones
encountered issues during processing.
Tr-   zCAnnotated[list[ProcessedRequest], Field(alias='processedRequests')]processed_requestszGAnnotated[list[UnprocessedRequest], Field(alias='unprocessedRequests')]unprocessed_requestsr   Nr    r   r)   r*   rS   rS      s0     tt]abL[[R bacr)   rS   N) 
__future__r   r   typingr   r   r   r   pydanticr	   r
   r   r   typing_extensionsr   crawlee._typesr   crawlee._utils.docsr   crawlee._utils.urlsr   r   r   r,   r0   r2   r8   r=   r@   rI   rO   rS   r   r)   r*   <module>r]      s   "  9 9 B B % % * 1~s3 N<i < <0 N.o . . NcO c c NJ? J J$ N+) + +* N#5w|7L # # N?9 ? ?: N
Ky 
K 
K N9 9 9 Nd) d dr)   