o i @sUdZddlmZddlZddlZddlZddlmZmZddl m Z ddl m Z m Z ddl mZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z ddl!Z"dd l#m$Z$m%Z%m&Z&m'Z'ddl(Z)ddl*Z)ddl+Z)ddl,Z)ddl-Z)e Gd d d Z.Gd d d eZ/GdddeZ0GdddeZ1e ddGdddZ2eee3ee4ee5ee6ee fZ7de8d<ee3e7fZ9de8d<ee3e4e5e6e ee3fZ:de8d<ede3e4e5e6e ee3Z;GdddeZGd!d"d"e$ee;Z?Gd#d$d$eee;Z@e ddGd%d&d&e@e;ZAe ddGd'd(d(ee?ZBeBgd)eB_C *dudvd1d2ZDee3ee3e4e5e6ffZEde8d3<Gd4d5d5eZFGd6d7d7eZGGd8d9d9eGZHGd:d;d;eGZIGdd?d?eGZKGd@dAdAeGZLGdBdCdCeGZMGdDdEdEeFZNGdFdGdGeGZOGdHdIdIeHeOZPGdJdKdKeIeOZQGdLdMdMeJeOZRGdNdOdOeKeOZSGdPdQdQeLeOZTGdRdSdSeMeOZUeNeF_Ve ddGdTdUdUZWeWddddVeW_XGdWdXdXeZYe ddGdYdZdZZZGd[d\d\eZ[e ddGd]d^d^e[Z\e ddGd_d`d`e[Z]e^Z_dwdedfZ`dxdkdlZaebebjcebedjcebe4jedmejffZgdydqdrZhGdsdtdteZidS)zz%Common code used in the Temporal SDK.) annotationsN)ABCabstractmethod) dataclass)datetime timedelta)IntEnum)AnyCallableClassVar CollectionGenericIteratorListMappingOptionalSequenceTextTupleTypeTypeVarUnionget_type_hintsoverload) NamedTupleSelf TypeAlias get_originc@seZdZUdZeddZded< dZded< d Zd ed < d Z d ed< d Z ded< e dddZ dddZ dddZd S) RetryPolicyz.Options for retrying workflows and activities.)secondsrinitial_intervalg@floatbackoff_coefficientNzOptional[timedelta]maximum_intervalrintmaximum_attemptszOptional[Sequence[str]]non_retryable_error_typesproto$temporalio.api.common.v1.RetryPolicyreturncCs@t|j|j|dr|jnd|j|jr|jdSddS)z,Create a retry policy from the proto object.r$N)r!r#r$r&r')rr! ToTimedeltar#HasFieldr$r&r'r(r.W/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/temporalio/common.py from_protoDs  zRetryPolicy.from_protoNonecCsZ||j|j|j|_|j|jp|jd|j|_|jr+|j|jdSdS)z:Apply the fields in this policy to the given proto object.dN) _validater! FromTimedeltar#r$r&r'extendselfr(r.r.r/apply_to_protoSszRetryPolicy.apply_to_protocCs||jdkrdS|jdkrtd|jdkrtd|jr3|jdkr)td|j|jkr3td|jdkrr?r% temporalioapienumsv1WorkflowIdReusePolicy(WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATEALLOW_DUPLICATE4WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLYALLOW_DUPLICATE_FAILED_ONLY)WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATEREJECT_DUPLICATE-WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNINGTERMINATE_IF_RUNNINGr.r.r.r/rCu    rCc@rB)WorkflowIDConflictPolicyzHow already-running workflows of the same ID are handled on start. See :py:class:`temporalio.api.enums.v1.WorkflowIdConflictPolicy`. N)r<r=r>r?r%rDrErFrGWorkflowIdConflictPolicy'WORKFLOW_ID_CONFLICT_POLICY_UNSPECIFIED UNSPECIFIED WORKFLOW_ID_CONFLICT_POLICY_FAILFAIL(WORKFLOW_ID_CONFLICT_POLICY_USE_EXISTING USE_EXISTING.WORKFLOW_ID_CONFLICT_POLICY_TERMINATE_EXISTINGTERMINATE_EXISTINGr.r.r.r/rRrQrRc@sFeZdZdZeejjjj j Z eejjjj j Z eejjjj jZdS)QueryRejectConditionzWhether a query should be rejected in certain conditions. See :py:class:`temporalio.api.enums.v1.QueryRejectCondition`. N)r<r=r>r?r%rDrErFrGr\QUERY_REJECT_CONDITION_NONENONEQUERY_REJECT_CONDITION_NOT_OPENNOT_OPEN,QUERY_REJECT_CONDITION_NOT_COMPLETED_CLEANLYNOT_COMPLETED_CLEANLYr.r.r.r/r\s  r\T)frozenc@s.eZdZUdZded<d ddZdd d Zd S)RawValueaRepresentation of an unconverted, raw payload. This type can be used as a parameter or return type in workflows, activities, signals, and queries to pass through a raw payload. Encoding/decoding of the payload is still done by the system. z temporalio.api.common.v1.Payloadpayloadr*objectcCsd|jS)Pickle support.1)reSerializeToStringr;r.r.r/ __getstate__szRawValue.__getstate__stater1c Cs\t|tstdt||dddkstdt|dtjj j j |dddS)rgzExpected bytes state, got NrrhzBad version prefixre) isinstancebytes TypeErrortyper:rf __setattr__rDrEcommonrGPayload FromString)r7rkr.r.r/ __setstate__s zRawValue.__setstate__N)r*rf)rkrfr*r1)r<r=r>r?r@rjrtr.r.r.r/rds  rdrSearchAttributeValuesSearchAttributesSearchAttributeValueSearchAttributeValueTypec@seZdZdZeejjjj j Z eejjjj j Z eejjjj jZeejjjj jZeejjjj jZeejjjj jZeejjjj jZdS)SearchAttributeIndexedValueTypez(Server index type of a search attribute.N)r<r=r>r?r%rDrErFrGIndexedValueTypeINDEXED_VALUE_TYPE_TEXTTEXTINDEXED_VALUE_TYPE_KEYWORDKEYWORDINDEXED_VALUE_TYPE_INTINTINDEXED_VALUE_TYPE_DOUBLEDOUBLEINDEXED_VALUE_TYPE_BOOLBOOLINDEXED_VALUE_TYPE_DATETIMEDATETIMEINDEXED_VALUE_TYPE_KEYWORD_LIST KEYWORD_LISTr.r.r.r/rys ryc@seZdZdZeed6ddZeed7ddZeed8d d Zed9d dZ ed6ddZ d:ddZ d;ddZ e dd"d#Ze d?d%d&Ze d@d(d)Ze dAd+d,Ze dBd/d0Ze dCd3d4Zd5S)DSearchAttributeKeyzpTyped search attribute key representation. Use one of the ``for`` static methods here to create a key. r*strcCdS)zGet the name of the key.Nr.r;r.r.r/namezSearchAttributeKey.namerycCr)z%Get the server index typed of the keyNr.r;r.r.r/indexed_value_typerz%SearchAttributeKey.indexed_value_typeType[SearchAttributeValueType]cCr)zGet the Python type of value for the key. This may contain generics which cannot be used in ``isinstance``. :py:attr:`origin_value_type` can be used instead. Nr.r;r.r.r/ value_typeszSearchAttributeKey.value_typercCst|jp|jS)z:Get the Python type of value for the key without generics.)rrr;r.r.r/origin_value_typesz$SearchAttributeKey.origin_value_typecCsv|j}|tjkr dS|tjkrdS|tjkrdS|tjkrdS|tjkr&dS|tjkr-dS|tjkr4dSt d|) NrKeywordIntDoubleBoolDatetime KeywordListzUnrecognized type: ) rryr|r~rrrrrr:)r7 index_typer.r.r/_metadata_types        z!SearchAttributeKey._metadata_typevaluerx/SearchAttributeUpdate[SearchAttributeValueType]cCstt||S)zUCreate a search attribute update to set the given value on this key. _SearchAttributeUpdaterx)r7rr.r.r/ value_setszSearchAttributeKey.value_setcCstt|dS)z@Create a search attribute update to unset the value on this key.Nrr;r.r.r/ value_unset"szSearchAttributeKey.value_unsetrSearchAttributeKey[str]cCtt|tjtS)z&Create a 'Text' search attribute type.)_SearchAttributeKeyrryr|rr.r.r/for_text&zSearchAttributeKey.for_textcCr)z)Create a 'Keyword' search attribute type.)rrryr~rr.r.r/ for_keyword+zSearchAttributeKey.for_keywordSearchAttributeKey[int]cCr)z&Create an 'Int' search attribute type.)rr%ryrrr.r.r/for_int2rzSearchAttributeKey.for_intSearchAttributeKey[float]cCr)z(Create a 'Double' search attribute type.)rr"ryrrr.r.r/ for_float7rzSearchAttributeKey.for_floatSearchAttributeKey[bool]cCr)z&Create a 'Bool' search attribute type.)rboolryrrr.r.r/for_bool>rzSearchAttributeKey.for_boolSearchAttributeKey[datetime]cCr)z*Create a 'Datetime' search attribute type.)rrryrrr.r.r/ for_datetimeErzSearchAttributeKey.for_datetime!SearchAttributeKey[Sequence[str]]cCsttt|tjttS)z-Create a 'KeywordList' search attribute type.)rrrryrrr.r.r/for_keyword_listLs z#SearchAttributeKey.for_keyword_list metadata_typeOptional[SearchAttributeKey]cCs|dkr t|S|dkrt|S|dkrt|S|dkr$t|S|dkr-t|S|dkr6t|S|dkr?t|SdS)Nrrrrrrr)rrrrrrrr)rrr.r.r/_from_metadata_typeVs       z&SearchAttributeKey._from_metadata_typevalsrucCs|sdSt|dkrt|dtrt|SdSt|dtr$t|St|dtr0t|St|dtrr?propertyrrrrrrrrrArrrrrrrrrr.r.r.r/rsF            rc@sPeZdZUded<ded<ded<eddd Zedd d Zedd d ZdS)rr_namery_indexed_value_typer _value_typer*cC|jSNrr;r.r.r/rz_SearchAttributeKey.namecCrr)rr;r.r.r/rrz&_SearchAttributeKey.indexed_value_typecCrr)rr;r.r.r/rrz_SearchAttributeKey.value_typeNrrr)r<r=r>r@rrrrr.r.r.r/rs   rc@s"eZdZUdZded<ded<dS)SearchAttributePairz=A named tuple representing a key/value search attribute pair.,SearchAttributeKey[SearchAttributeValueType]keyrxrN)r<r=r>r?r@r.r.r.r/rs  rc@s4eZdZdZeed ddZeed ddZd S) SearchAttributeUpdatez,Representation of a search attribute update.r*rcCr)zKey that is being set.Nr.r;r.r.r/rrzSearchAttributeUpdate.key"Optional[SearchAttributeValueType]cCr)z3Value that is being set or ``None`` if being unset.Nr.r;r.r.r/rrzSearchAttributeUpdate.valueNr*rr*r)r<r=r>r?rrrrr.r.r.r/rsrc@s:eZdZUded<ded<ed ddZed dd Zd S) rr_keyr_valuer*cCrr)rr;r.r.r/rrz_SearchAttributeUpdate.keycCrr)rr;r.r.r/rrz_SearchAttributeUpdate.valueNrr)r<r=r>r@rrrr.r.r.r/rs  rc@seZdZUdZded< ded< ddZd&d d Zd'ddZd(ddZd)ddZ e d*ddZ e d+ddZ d,d-d"dZ d.d$d%Z dS)/TypedSearchAttributeszCollection of typed search attributes. This is represented as an immutable collection of :py:class:`SearchAttributePair`. This can be created passing a sequence of pairs to the constructor. zSequence[SearchAttributePair]search_attributeszClassVar[TypedSearchAttributes]emptycCsht|dt|jdddt|jD]\}}|dkr1|j|djj|jjkr1td|jjqdS) zPost-init initialization.rcSs|jjSrrr)pairr.r.r/sz5TypedSearchAttributes.__post_init__..rrrz1Duplicate search attribute entries found for key N)rfrpsortedr enumeraterrr:)r7irr.r.r/ __post_init__s" z#TypedSearchAttributes.__post_init__r*r%cC t|jS)z$Get the number of search attributes.)rrr;r.r.r/__len__ zTypedSearchAttributes.__len__rrrxcs*tfdd|Dd}|durt|S)zVGet a single search attribute value by key or fail with ``KeyError``. c3s |] \}}|kr|VqdSrr..0kvrr.r/ sz4TypedSearchAttributes.__getitem__..N)nextKeyError)r7rretr.rr/ __getitem__sz!TypedSearchAttributes.__getitem__Iterator[SearchAttributePair]cCr)z6Get an iterator over search attribute key/value pairs.)iterrr;r.r.r/__iter__rzTypedSearchAttributes.__iter__rfrcstfdd|DS)zCheck whether this search attribute contains the given key. This uses key equality so the key must be the same name and type. c3s|] \}}|kVqdSrr.rrr.r/rsz5TypedSearchAttributes.__contains__..)anyr7rr.rr/ __contains__sz"TypedSearchAttributes.__contains__rcCdSrr.rr.r.r/getzTypedSearchAttributes.getdefaulttemporalio.types.AnyType9Union[SearchAttributeValueType, temporalio.types.AnyType]cCrrr.r7rrr.r.r/rsN Optional[Any]r cCs$z||WSty|YSw)z\Get an attribute value for a key (or default). This is similar to dict.get. )rrrr.r.r/rs   rcsTt|j}|D]tfddt|Dd}|dur!|q||<qt|S)zvCopy this collection, replacing attributes with matching key names or adding if key name not present. c3s(|]\}}jj|jjkr|VqdSrr)rr index_attrattrr.r/rsz0TypedSearchAttributes.updated..N)listrrrappendr)r7rattrsexisting_indexr.rr/updateds    zTypedSearchAttributes.updated)r*r%)rrr*rx)r*r)rrfr*r)rrr*r)rrrrr*rr)rrrrr*r )rrr*r) r<r=r>r?r@rrrrrrrrr.r.r.r/rs$        r)r attributes&Optional[Union[SearchAttributes, Any]] stack_levelr%r*r1cCs.|rt|trtjdtd|ddSdSdS)Nz1Dictionary-based search attributes are deprecatedr) stacklevel)rlrwarningswarnDeprecationWarning)rrr.r.r/%_warn_on_deprecated_search_attributes's rMetricAttributesc@seZdZUdZded< e d!d"d d Ze d!d#ddZe d!d$ddZe d!d%ddZ e d!d&ddZ e d!d'ddZ ed(dd Z dS)) MetricMeterz#Metric meter for recording metrics.zClassVar[MetricMeter]noopNrr description Optional[str]unitr* MetricCountercCr)aCreate a counter metric for adding values. Args: name: Name for the metric. description: Optional description for the metric. unit: Optional unit for the metric. Returns: Counter metric. Nr.r7rrrr.r.r/create_counter<zMetricMeter.create_counterMetricHistogramcCra Create a histogram metric for recording values. Args: name: Name for the metric. description: Optional description for the metric. unit: Optional unit for the metric. Returns: Histogram metric. Nr.r r.r.r/create_histogramLr zMetricMeter.create_histogramMetricHistogramFloatcCrrr.r r.r.r/create_histogram_float\r z"MetricMeter.create_histogram_floatMetricHistogramTimedeltacCr)aCreate a histogram metric for recording values. Note, duration precision is millisecond. Also note, if "unit" is set as "duration", it will be converted to "ms" or "s" on the way out. Args: name: Name for the metric. description: Optional description for the metric. unit: Optional unit for the metric. Returns: Histogram metric. Nr.r r.r.r/create_histogram_timedeltalz&MetricMeter.create_histogram_timedelta MetricGaugecCraCreate a gauge metric for setting values. Args: name: Name for the metric. description: Optional description for the metric. unit: Optional unit for the metric. Returns: Gauge metric. Nr.r r.r.r/ create_gauger zMetricMeter.create_gaugeMetricGaugeFloatcCrrr.r r.r.r/create_gauge_floatr zMetricMeter.create_gauge_floatadditional_attributesrcCr)a[Create a new metric meter with the given attributes appended to the current set. Args: additional_attributes: Additional attributes to append to the current set. Returns: New metric meter. Raises: TypeError: Attribute values are not the expected type. Nr.r7rr.r.r/with_additional_attributesrz&MetricMeter.with_additional_attributesNNrrrrrrr*r rrrrrrr*r rrrrrrr*rrrrrrrr*rrrrrrrr*rrrrrrrr*rrrr*r) r<r=r>r?r@rr rrrrrrr.r.r.r/r6s0 rc@sTeZdZdZeedddZeedddZeedd d ZedddZ dS) MetricCommonzBase for all metrics.r*rcCr)zName for the metric.Nr.r;r.r.r/rrzMetricCommon.namercCr)z"Description for the metric if any.Nr.r;r.r.r/rrzMetricCommon.descriptioncCr)zUnit for the metric if any.Nr.r;r.r.r/rrzMetricCommon.unitrrrcCr)aOCreate a new metric with the given attributes appended to the current set. Args: additional_attributes: Additional attributes to append to the current set. Returns: New metric. Raises: TypeError: Attribute values are not the expected type. Nr.rr.r.r/rrz'MetricCommon.with_additional_attributesNrr*rrrr*r) r<r=r>r?rrrrrrr.r.r.r/r%sr%c@"eZdZdZe d d d d ZdS) r z)Counter metric created by a metric meter.Nrr%rOptional[MetricAttributes]r*r1cCr)aKAdd a value to the counter. Args: value: A non-negative integer to add. additional_attributes: Additional attributes to append to the current set. Raises: ValueError: Value is negative. TypeError: Attribute values are not the expected type. Nr.r7rrr.r.r/addzMetricCounter.addrrr%rr)r*r1)r<r=r>r?rr+r.r.r.r/r  r c@r() r +Histogram metric created by a metric meter.Nrr%rr)r*r1cCr)aSRecord a value on the histogram. Args: value: A non-negative integer to record. additional_attributes: Additional attributes to append to the current set. Raises: ValueError: Value is negative. TypeError: Attribute values are not the expected type. Nr.r*r.r.r/recordr,zMetricHistogram.recordrr-r<r=r>r?rr0r.r.r.r/r r.r c@r() rr/Nrr"rr)r*r1cCr)aQRecord a value on the histogram. Args: value: A non-negative float to record. additional_attributes: Additional attributes to append to the current set. Raises: ValueError: Value is negative. TypeError: Attribute values are not the expected type. Nr.r*r.r.r/r0 r,zMetricHistogramFloat.recordrrr"rr)r*r1r1r.r.r.r/rr.rc@r() rr/Nrrrr)r*r1cCr)aRecord a value on the histogram. Note, duration precision is millisecond. Args: value: A non-negative timedelta to record. additional_attributes: Additional attributes to append to the current set. Raises: ValueError: Value is negative. TypeError: Attribute values are not the expected type. Nr.r*r.r.r/r0rzMetricHistogramTimedelta.recordrrrrr)r*r1r1r.r.r.r/rr.rc@r() r'Gauge metric created by a metric meter.Nrr%rr)r*r1cCr)aISet a value on the gauge. Args: value: A non-negative integer to set. additional_attributes: Additional attributes to append to the current set. Raises: ValueError: Value is negative. TypeError: Attribute values are not the expected type. Nr.r*r.r.r/set5r,zMetricGauge.setrr-r<r=r>r?rr5r.r.r.r/r2r.rc@r() rr4Nrr"rr)r*r1cCr)aGSet a value on the gauge. Args: value: A non-negative float to set. additional_attributes: Additional attributes to append to the current set. Raises: ValueError: Value is negative. TypeError: Attribute values are not the expected type. Nr.r*r.r.r/r5Jr,zMetricGaugeFloat.setrr2r6r.r.r.r/rGr.rc@sjeZdZ dd d d Z dd!d d Z dd"ddZ dd#ddZ dd$ddZ dd%ddZd&ddZ dS)'_NoopMetricMeterNrrrrrr*r cC t|||Sr)_NoopMetricCounterr r.r.r/r ] z_NoopMetricMeter.create_counterr cCr8r)_NoopMetricHistogramr r.r.r/rbr:z!_NoopMetricMeter.create_histogramrcCr8r)_NoopMetricHistogramFloatr r.r.r/rgr:z'_NoopMetricMeter.create_histogram_floatrcCr8r)_NoopMetricHistogramTimedeltar r.r.r/rlr:z+_NoopMetricMeter.create_histogram_timedeltarcCr8r)_NoopMetricGauger r.r.r/rqr:z_NoopMetricMeter.create_gaugercCr8r)_NoopMetricGaugeFloatr r.r.r/rvr:z#_NoopMetricMeter.create_gauge_floatrrrcC|Srr.rr.r.r/r{rz+_NoopMetricMeter.with_additional_attributesrrrr r!r"r#r$) r<r=r>r rrrrrrr.r.r.r/r7\s      r7c@sJeZdZddd Zedd d Zedd d ZedddZdddZdS) _NoopMetricrrrrrr*r1cCs||_||_||_dSr)r _description_unitr r.r.r/__init__s z_NoopMetric.__init__cCrrrr;r.r.r/rrz_NoopMetric.namecCrr)rBr;r.r.r/rrz_NoopMetric.descriptioncCrr)rCr;r.r.r/rrz_NoopMetric.unitrrrcCr@rr.rr.r.r/rrz&_NoopMetric.with_additional_attributesN)rrrrrrr*r1rr&r') r<r=r>rDrrrrrr.r.r.r/rAs    rAc@eZdZ d d dd ZdS) r9Nrr%rr)r*r1cCrrr.r*r.r.r/r+rz_NoopMetricCounter.addrr-)r<r=r>r+r.r.r.r/r9r9c@rE) r;Nrr%rr)r*r1cCrrr.r*r.r.r/r0rz_NoopMetricHistogram.recordrr-r<r=r>r0r.r.r.r/r;rFr;c@rE) r<Nrr"rr)r*r1cCrrr.r*r.r.r/r0rz _NoopMetricHistogramFloat.recordrr2rGr.r.r.r/r<rFr<c@rE) r=Nrrrr)r*r1cCrrr.r*r.r.r/r0rz$_NoopMetricHistogramTimedelta.recordrr3rGr.r.r.r/r=rFr=c@rE) r>Nrr%rr)r*r1cCrrr.r*r.r.r/r5rz_NoopMetricGauge.setrr-r<r=r>r5r.r.r.r/r>rFr>c@rE) r?Nrr"rr)r*r1cCrrr.r*r.r.r/r5rz_NoopMetricGaugeFloat.setrr2rHr.r.r.r/r?rFr?c@sfeZdZUdZdZded< dZded< dZded< d ed < edddZ dddZ ddZ dS)PriorityazPriority contains metadata that controls relative ordering of task processing when tasks are backlogged in a queue. Initially, Priority will be used in activity and workflow task queues, which are typically where backlogs exist. Priority is (for now) attached to workflows and activities. Activities and child workflows inherit Priority from the workflow that created them, but may override fields when they are started or modified. For each field of a Priority on an activity/workflow, not present or equal to zero/empty string means to inherit the value from the calling workflow, or if there is no calling workflow, then use the default (documented on the field). The overall semantics of Priority are: 1. First, consider "priority_key": lower number goes first. 2. Then consider "fairness_key" and "fairness_weight" for fairness balancing. Nz Optional[int] priority_keyr fairness_keyzOptional[float]fairness_weightzClassVar[Priority]rr(!temporalio.api.common.v1.Priorityr*cCs6t|jr|jnd|jr|jnd|jr|jdSddS)z1Create a Priority instance from the proto object.NrJrKrL)rIrJrKrLr-r.r.r/ _from_protos zPriority._from_protocCs@tjjjj|jp dd}|jdur|j|_|jdur|j|_|S)Nr)rJ)rDrErqrGrIrJrKrLr6r.r.r/ _to_protos   zPriority._to_protocCs8|jdurt|jtstd|jdkrtddSdS)zValidates priority settings.Nzpriority_key must be an integerrz'priority_key must be a positive integer)rJrlr%rnr:r;r.r.r/rs   zPriority.__post_init__)r(rMr*rI)r*rM) r<r=r>r?rJr@rKrLrArOrPrr.r.r.r/rIs        rIrNc@s>eZdZdZejjjjj Z ejjjjj Z ejjjjj ZdS)VersioningBehaviorzsSpecifies when a workflow might move from a worker of one Build Id to another. WARNING: Experimental API. N)r<r=r>r?rDrErFrGrQVERSIONING_BEHAVIOR_UNSPECIFIEDrUVERSIONING_BEHAVIOR_PINNEDPINNED VERSIONING_BEHAVIOR_AUTO_UPGRADE AUTO_UPGRADEr.r.r.r/rQs  rQc@sDeZdZUdZded<ded<dddZedd d Zdd d ZdS)WorkerDeploymentVersionz\Represents the version of a specific worker deployment. WARNING: Experimental API. rdeployment_namebuild_idr*cCs|jd|jS)z;Returns the canonical string representation of the version..)rXrYr;r.r.r/to_canonical_string<sz+WorkerDeploymentVersion.to_canonical_string canonicalcCs<|jddd}t|dkrtd|dt|d|dS)zParse a version from a canonical string, which must be in the format `.`. Deployment name must not have a `.` in it. rZr)maxsplitrzCannot parse version string: z0, must be in format .r)splitrr:rW)r\partsr.r.r/from_canonical_string@s   z-WorkerDeploymentVersion.from_canonical_string4temporalio.api.deployment.v1.WorkerDeploymentVersioncCstjjjj|j|jdS) Convert to proto representation.)rYrX)rDrE deploymentrGrWrYrXr;r.r.r/rPLs z!WorkerDeploymentVersion._to_protoNr)r\rr*rW)r*ra) r<r=r>r?r@r[rAr`rPr.r.r.r/rW2s    rWc@seZdZdZedddZdS)VersioningOverridezRepresents the override of a worker's versioning behavior for a workflow execution. .. warning:: Experimental API. r*-temporalio.api.workflow.v1.VersioningOverridecCr)rbNr.r;r.r.r/rP[rzVersioningOverride._to_protoNr*re)r<r=r>r?rrPr.r.r.r/rdTsrdc@s$eZdZUdZded<d ddZdS) PinnedVersioningOverridezjWorkflow will be pinned to a specific deployment version. .. warning:: Experimental API. rWversionr*recCsJtjjjjtjjjjj|j tjjjjj |j tjjjjj j ddS)rb)rhbehavior)ripinned_versionpinned)rDrEworkflowrGrdrFrQrSrhr[PinnedOverriderPPinnedOverrideBehaviorPINNED_OVERRIDE_BEHAVIOR_PINNEDr;r.r.r/rPks   z"PinnedVersioningOverride._to_protoNrf)r<r=r>r?r@rPr.r.r.r/rgas rgc@seZdZdZdddZdS)AutoUpgradeVersioningOverridezThe workflow will auto-upgrade to the current deployment version on the next workflow task. .. warning:: Experimental API. r*recCstjjjjtjjjjjddS)rbT)ri auto_upgrade)rDrErlrGrdrFrQrUr;r.r.r/rPs  z'AutoUpgradeVersioningOverride._to_protoNrf)r<r=r>r?rPr.r.r.r/rpxsrpargr args Sequence[Any]cCs|tur |r td|g}|S)NzCannot have arg and args) _arg_unsetr:)rrrsr.r.r/ _arg_or_argss rvsource8Optional[Mapping[str, temporalio.api.common.v1.Payload]]destVgoogle.protobuf.internal.containers.MessageMap[Text, temporalio.api.common.v1.Payload]cCs0|durdS|D] \}}|||q dSr)itemsCopyFrom)rwryrrr.r.r/_apply_headerss r} from_bytesfuncr +Tuple[Optional[List[Type]], Optional[Type]]c Cs2t|s,t|ts,t|tjs,t|tr|nt|}t|dd}|dur,t|ts,|}t|}t |}| d}|tj j urB|nd}g}t |jD]G\}} |dkri| jdkri| jtjj usht| jdkriqM| jtjjur}| jtjjur}d|fS| | j} | tjj urd|fS|| qM||fS)aExtracts the type hints from the function. Args: func: Function to extract hints from. Returns: Tuple containing parameter types and return type. The parameter types will be None if there are any non-positional parameters or if any of the parameters to not have an annotation that represents a class. If the first parameter is "self" with no attribute, it is not included. __call__Nr*rr7z typing.Self)inspect isfunctionrl_non_user_defined_callablestypes MethodTyperogetattr signaturerr Signaturerr parametersvaluesr annotation ParameterrkindPOSITIONAL_ONLYPOSITIONAL_OR_KEYWORDr) rtmp_func call_funcsighintsret_hintrrsindexrarg_hintr.r.r/_type_hints_from_funcs>           rc@s eZdZdZdZ dZ dZdS)HeaderCodecBehaviorz(Different ways to handle header encodingrrN)r<r=r>r?NO_CODECCODECWORKFLOW_ONLY_CODECr.r.r.r/rsr)r)rrrr%r*r1)rrr rsrtr*rt)rwrxryrzr*r1)rr r*r)jr? __future__rrrrabcrr dataclassesrrrenumrtypingr r r r r rrrrrrrrrrrr#google.protobuf.internal.containersgoogletyping_extensionsrrrrtemporalio.api.common.v1rDtemporalio.api.deployment.v1temporalio.api.enums.v1temporalio.api.workflow.v1temporalio.typesrrCrRr\rdrr%r"rrur@rvrwrxryrrrrrrrrrrr%r r rrrrr7rAr9r;r<r=r>r?rrIrrQrWrdrgrprfrurvr}rorall__dict__BuiltinFunctionTyperrrr.r.r.r/s   LJ     j })%R!     B