iOddlZddlZGddejZejdeejdZ Gdde Z e j de j d e jd e jd e jd e jd e jde jde jde jde jdi e _e j e j e je je je je je je je je jd e _dZGdde ZGdde Zejejejejej ej!ej"ej#de_dej$De_Gdde Z%Gdde Z&Gdd e Z'Gd!d"e'Z(Gd#d$e'Z)Gd%d&e*Z+Gd'd(e+Z,Gd)d*e,Z-Gd+d,e,Z.Gd-d.e.Z/Gd/d0e.Z0Gd1d2e,Z1Gd3d4e,Z2Gd5d6e2Z3Gd7d8e2Z4Gd9d:e,Z5Gd;de6Z7Gd?d@e7Z8GdAdBe6Z9GdCdDe6Z:GdEdFe+Z;GdGdHe+Z<GdIdJe+Z=GdKdLe+Z>GdMdNe*Z?dS)ONceZdZdZdS) NullHandlercdSN)selfrecords d/Users/user/workspace/sujinbaek/cqa-test-app/venv/lib/python3.11/site-packages/cassandra/__init__.pyemitzNullHandler.emits N)__name__ __module__ __qualname__r rr r rrs#     r r cassandrazcassandra-drivercjeZdZdZdZ dZ dZ dZ dZ dZ dZ d Z d Z d Z d Z ed ZdS)ConsistencyLevelz Specifies how many replicas must respond for an operation to be considered a success. By default, ``ONE`` is used for all operations. r cB|tjkp|tjkSr)rSERIAL LOCAL_SERIAL)cls r is_serialzConsistencyLevel.is_serial_s%,,S6F6S0SSr N)r rr__doc__ANYONETWOTHREEQUORUMALL LOCAL_QUORUM EACH_QUORUMrr LOCAL_ONE staticmethodr!rr r rrs C C C EF CLKF L I TT\TTTr rr#r$r%r&r'r(r)r*rrr+) r#r$r%r&r'r(r)r*rrr+c.|tj|ndS)NzNot Set)r value_to_name)values r consistency_value_to_namer0s494E  )% 0 09Tr cVeZdZdZdZ dZ dZ dZ dZ dZ dZ d Z e e e eeeeefZ e fZ ee Z ee Z ed Zed Zed Zed ZedZedZedZedZedZdS)ProtocolVersionzD Defines native protocol versions supported by this driver. rrrrrrABc tfdttjdD}n#t$rd}YnwxYw|S)zY Return the lower supported protocol version. Beta versions are omitted. c3DK|]}|tjv|k|VdSr)r2 BETA_VERSIONS).0vprevious_versions r z6ProtocolVersion.get_lower_supported..sK\\O$AAAaJZFZFZFZFZFZFZ\\r T)reverser)nextsortedr2SUPPORTED_VERSIONS StopIteration)clsr:versions ` r get_lower_supportedz#ProtocolVersion.get_lower_supporteds  \\\\f_-OY]&^&^&^\\\\\GG   GGG s48 AAc||jkSrV5rArBs r uses_int_query_flagsz$ProtocolVersion.uses_int_query_flags#&  r c.||jko ||jkSrrFDSE_V1rGs r uses_prepare_flagsz"ProtocolVersion.uses_prepare_flags#& :W %::r c.||jko ||jkSrrKrGs r uses_prepared_metadataz&ProtocolVersion.uses_prepared_metadatarNr c||jkSrrErGs r uses_error_code_mapz#ProtocolVersion.uses_error_code_maprIr c.||jko ||jkSrrKrGs r uses_keyspace_flagz"ProtocolVersion.uses_keyspace_flagrNr c||jkSr)rLrGs r has_continuous_paging_supportz-ProtocolVersion.has_continuous_paging_support#*$$r c||jkSr)DSE_V2rGs r has_continuous_paging_next_pagesz0ProtocolVersion.has_continuous_paging_next_pagesrWr c6|j|cxko |jkncSrrKrGs r has_checksumming_supportz(ProtocolVersion.has_checksumming_supports(v----3:-----r N)r rrr"V1V2V3V4rFV6rLrYr?r7min MIN_SUPPORTEDmax MAX_SUPPORTED classmethodrCrHrMrPrRrTrVrZr\rr r r2r2s B B B B B BFF!&"b"b"bAEMC*++MC*++M  [ !![!;;[;;;[;!![!;;[;%%[%%%[%..[...r r2c@eZdZdZdZ dZ dZ dZ dZ dZ dZ d Z d S) WriteTypez] For usage with :class:`.RetryPolicy`, this describes a type of write operation. rrrrrrrrN) r rrr"SIMPLEBATCHUNLOGGED_BATCHCOUNTER BATCH_LOGCASVIEWCDCrr r rhrhsy F E N G I C D Cr rh)rirjrkrlrmrnrorpci|]\}}|| Srr)r8kr9s r rs:sLLLDAq1aLLLr ceZdZdZdZdZdS)SchemaChangeTypeDROPPEDCREATEDUPDATEDN)r rrrvrwrxrr r ruru=sGGGGGr ruc"eZdZdZdZdZdZdZdS)SchemaTargetTypeKEYSPACETABLETYPEFUNCTION AGGREGATEN)r rrr{r|r}r~rrr r rzrzCs'H E DHIIIr rzcFeZdZdZedZedZdZdS)SignatureDescriptorc"||_||_dSrnameargument_types)rrrs r __init__zSignatureDescriptor.__init__Ms ,r cB||j|jS)z function signature string in the form 'name([type0[,type1[...]]])' can be used to uniquely identify overloaded function names within a keyspace )format_signaturerrrs r signaturezSignatureDescriptor.signatureQs$$TY0CDDDr cL|ddd|DdS)N(,c3K|]}|VdSrr)r8ts r r;z7SignatureDescriptor.format_signature..\s")D)D!)D)D)D)D)D)Dr ))joinrs r rz$SignatureDescriptor.format_signatureZs244)D)D^)D)D)D!D!D!D!DEEr c@|jjd|jd|jdS)Nrz, r) __class__r rrrs r __repr__zSignatureDescriptor.__repr__^s)#~666 4CVCVCVWWr N) r rrrpropertyrr,rrrr r rrKss---EEXEFF\FXXXXXr rceZdZdZdZ dZdS)UserFunctionDescriptorzB Describes a User function by name and argument signature Nr rrr"rrrr r rrb1 DNr rceZdZdZdZ dZdS)UserAggregateDescriptorzL Describes a User aggregate function by name and argument signature Nrrr r rrrrr rceZdZdZdS)DriverExceptionzB Base for all exceptions explicitly raised by the driver. Nr rrr"rr r rr Dr rceZdZdZdS)RequestExecutionExceptionzI Base for request execution exceptions returned from the server. Nrrr r rrrr rc,eZdZdZdZ dZ dZ ddZdS) Unavailablez There were not enough live replicas to satisfy the requested consistency level, so the coordinator node immediately failed the request without forwarding it to any replicas. Nc ||_||_||_t||dzt t |||dzdS)N info=) consistencyrequired_replicasalive_replicas)rrr Exceptionrreprr0)rsummary_messagerrrs r rzUnavailable.__init__s|&!2,48!;0I+0V0V6G3A!C!CDD"D E E E E Er NNN)r rrr"rrrrrr r rrsS K3SN;EEEEEEr rc0eZdZdZdZ dZ dZ ddZdS)TimeoutzO Replicas failed to respond to the coordinator node before timing out. Nc ||_||_||_d|vrtj|d|d<t |||d}||t||dzt|zdS)N write_type)rrequired_responsesreceived_responsesr) rrrrhr.r0updaterrr)rrrrrkwargsinfos r rzTimeout.__init__s&"4"4 6 ! !#,#:6,;O#PF< 8EE&8&8:: F48!;d4jj!HIIIIIr r)r rrr"rrrrrr r rrs`K34 NR$(JJJJJJr rc eZdZdZdZ ddZdS) ReadTimeouta< A subclass of :exc:`Timeout` for read operations. This indicates that the replicas failed to respond to the coordinator node before the configured timeout. This timeout is configured in ``cassandra.yaml`` with the ``read_request_timeout_in_ms`` and ``range_request_timeout_in_ms`` options. Nc :tj||fi|||_dSr)rrdata_retrievedrmessagerrs r rzReadTimeout.__init__s+w11&111,r rr rrr"rrrr r rrs>N ------r rc eZdZdZdZ ddZdS) WriteTimeouta A subclass of :exc:`Timeout` for write operations. This indicates that the replicas failed to respond to the coordinator node before the configured timeout. This timeout is configured in ``cassandra.yaml`` with the ``write_request_timeout_in_ms`` option. Nc D||d<tj||fi|||_dS)Nr)rrrrrrrs r rzWriteTimeout.__init__s2)|w11&111$r rr rrr"rrrr r rrs>J%%%%%%r rceZdZdZdZdS)CDCWriteFailurez> Hit limit on data in CDC folder, writes are rejected c<t||dSr)rr)rrs r rzCDCWriteFailure.__init__s4)))))r N)r rrr"rrr r rrs-*****r rc<eZdZdZdZ dZ dZ dZ dZ ddZ dS)CoordinationFailurez5 Replicas sent a failure to the coordinator. Nc4||_||_||_||_||_t ||||d}|0t d|D}||d<t ||dzt|zdS)N)rrrfailuresc3*K|]\}}|d|zfVdS)z0x%04xNr)r8addrerr_codes r r;z/CoordinationFailure.__init__..,sL!Q!Q%5dH#'8(;!<!Q!Q!Q!Q!Q!Qr error_code_mapr) rrrrrr0dictitemsrrr) rrrrrrr info_dict formatted_maps r rzCoordinationFailure.__init__s&"4"4  ,5[AA"4"4     % !Q!Q9G9M9M9O9O!Q!Q!QQQM*7I& '48!;d9oo!MNNNNNr )NNNNN) r rrr"rrrrrrrr r rrsxK34 HN NRHLOOOOOOr rc eZdZdZdZ ddZdS) ReadFailurez A subclass of :exc:`CoordinationFailure` for read operations. This indicates that the replicas sent a failure message to the coordinator. Nc :tj||fi|||_dSr)rrrrs r rzReadFailure.__init__As+$T7==f===,r rrrr r rr3s> N ------r rc eZdZdZdZ ddZdS) WriteFailurez A subclass of :exc:`CoordinationFailure` for write operations. This indicates that the replicas sent a failure message to the coordinator. Nc :tj||fi|||_dSr)rrrrs r rzWriteFailure.__init__Rs($T7==f===$r rrrr r rrFs> J%%%%%%r rc*eZdZdZdZ dZ dZ dZdS)FunctionFailurez7 User Defined Function failed during execution Ncf||_||_||_t||dSr)keyspacefunction arg_typesrr)rrrrrs r rzFunctionFailure.__init__ks3    "411111r )r rrr"rrrrrr r rrWsQHHI22222r rceZdZdZdS)RequestValidationExceptionz* Server request validation failed Nrrr r rrrrr rceZdZdZdS)ConfigurationExceptionzE Server indicated request errro due to current configuration Nrrr r rryrr rc&eZdZdZdZ dZ ddZdS) AlreadyExistszP An attempt was made to create a keyspace or table that already exists. Nc||r d|d|d}nd|d}t||||_||_dS)NzTable '.z' already existsz Keyspace ')rrrtable)rrrrs r rzAlreadyExists.__init__sb  C C8@%%%HGG C9ABG4)))   r NN)r rrr"rrrrr r rrsJH E r rceZdZdZdS)InvalidRequestz A query was made that was invalid for some reason, such as trying to set the keyspace for a connection to a nonexistent keyspace. Nrrr r rrs Dr rceZdZdZdS) UnauthorizedzP The current user is not authorized to perform the requested operation. Nrrr r rrrr rceZdZdZdS)AuthenticationFailedz! Failed to authenticate. Nrrr r rrrr rc&eZdZdZdZ dZ ddZdS)OperationTimedOutz The operation took longer than the specified (client-side) timeout to complete. This is not an error generated by Cassandra, only the driver. Nc|||_||_d|jd|j}t||dS)Nzerrors=z , last_host=)errors last_hostrr)rrrrs r rzOperationTimedOut.__init__sB "/3{{{DNNK4)))))r r)r rrr"rrrrr r rrsJ FI******r rceZdZdZdS)UnsupportedOperationz An attempt was made to use a feature that is not supported by the selected protocol version. See :attr:`Cluster.protocol_version` for more details. Nrrr r rrs  Dr rceZdZdZdS)UnresolvableContactPointsz The driver was unable to resolve any provided hostnames. Note that this is *not* raised when a :class:`.Cluster` is created with no contact points, only when lookup fails for all hosts Nrrr r rrs  Dr rc"eZdZdZgZ gfdZdS)DependencyExceptionzO Specific exception class for handling issues with driver dependencies c|}|r%|ddd|Dzz }t||dS)Nz- The following exceptions were observed: - z - c34K|]}t|VdSr)str)r8es r r;z/DependencyException.__init__..s-]s]sij^abc^d^d]s]s]s]s]s]sr )rrr)rmsgexcs complete_msgs r rzDependencyException.__init__s[  u NQXQ]Q]]s]snr]s]s]sQsQss tL4.....r N)r rrr"rrrr r rrsC D"$//////r r)@loggingimportlib.metadata importlibHandlerr getLogger addHandlermetadatarB __version__objectrr#r$r%r&r'r(r)r*rrr+r. name_to_valuer0r2rhrirjrkrlrmrnrorprrurzrrrrrrrrrrrrrrrrrrrrrrrrrrr r r s"     '/   +))++--888 (();<< DTDTDTDTDTvDTDTDTP%%%GX%!> -X!>  "        #%  $1#/%$1!+ " "UUUp.p.p.p.p.fp.p.p.f33333333n _. $ = N =   MLI,C,I,I,K,KLLL v vXXXXX&XXX.     0        1         i           EEEEE+EEE4JJJJJ'JJJD-----'---,%%%%%7%%%******/***1O1O1O1O1O31O1O1Oh-----%---&%%%%%&%%%"22222/2226             7   *8     /        -        ?   ********0     ?           /////)/////r