1ZSrSSKJr SSKJr SrSSKr\R RS5S:Xa%SSKJ r SS KJ r SS KJ r SS KJ r SS KJ r SS KJr O$SSKJ r SS KJ r SS KJ r SS KJ r SS KJ r SS KJr SrSrSrSrSrSrSrS\<S\<S3rSrSrSrSrSrSrSr Sr!S r"S!r#S"r$S#r%S$r&S%r'S&r(S'r)S(r*S)r+S*r,"S+S,\-5r."S-S.\ R^5r0"S/S0\ R^5r1"S1S2\ R^5r2"S3S4\ R^5r3S:S5jr4S6r5S7r6S8r7S9r8g);aQueueInfo tools. QueueInfo is a library for working with QueueInfo records, describing task queue entries for an application. QueueInfo loads the records from `queue.yaml`. To learn more about the parameters you can specify in `queue.yaml`, review the `queue.yaml reference guide`_. .. _queue.yaml reference guide: https://cloud.google.com/appengine/docs/python/config/queueref )absolute_import)unicode_literalszarb@google.com (Anthony Baxter)NAPPENGINE_RUNTIMEpython27)appinfo) validation) yaml_builder) yaml_listener) yaml_object)taskqueue_service_pbz^[A-Za-z0-9-]{0,499}$z^(0|[0-9]+(\.[0-9]*)?/[smhd])z^([0-9]+(\.[0-9]*)?[BKMGT]?)z(True)|(False)z (pull)|(push)z(?!-)[a-z\d\-]{1,63}z(?!-)[a-z\d\-]{1,100}z^(?:(?:(z)\.)?)(z)$queuenamerate bucket_sizemodetargetmax_concurrent_requeststotal_storage_limitresume_paused_queuesBKMGTretry_parameterstask_retry_limittask_age_limitmin_backoff_secondsmax_backoff_seconds max_doublingsacl user_email writer_emailc\rSrSrSrSrg)MalformedQueueConfigurationbz7The configuration file for the task queue is malformed.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r#-lib/googlecloudsdk/appengine/api/queueinfo.pyr!r!bs?r*r!c >\rSrSrSr\\R"\R5\ \R"\R"55\ \R"\R5\ \R"\R5\\R"\R50rSrg)RetryParametersfz7Specifies the retry parameters for a single task queue.r#N)r$r%r&r'r(TASK_RETRY_LIMITrOptionalTYPE_INTTASK_AGE_LIMIT TimeValueMIN_BACKOFF_SECONDS TYPE_FLOATMAX_BACKOFF_SECONDS MAX_DOUBLINGS ATTRIBUTESr)r#r*r+r-r-fs}? ++J,?,?@j))**>*>*@A:..z/D/DE:..z/D/DEZ(()<)<= *r*r-c\rSrSrSr\\R"\R5\ \R"\R50r Sr g)Aclqz9Controls the access control list for a single task queue.r#N) r$r%r&r'r( USER_EMAILrr0TYPE_STR WRITER_EMAILr8r)r#r*r+r:r:qs8A*%%j&9&9:J'' (;(;<*r*r:cd\rSrSrSr\\\\R"\ 5\ \R"\ 5\ \R"\R5\\R"\R5\\R"\5\\R"\R&"\55\\R"\50rSrg) QueueEntryyzDescribes a single task queue.r#N)r$r%r&r'r(NAME _NAME_REGEXRATErr0 _RATE_REGEXMODE _MODE_REGEX BUCKET_SIZEr1MAX_CONCURRENT_REQUESTSRETRY_PARAMETERSr-ACLRepeatedr:TARGET_VERSION_REGEXr8r)r#r*r+r@r@ys& K J   , J   ,:&&z':':;z22:3F3FG ++O< :  z2237 8 j!!.1 *r*r@c \rSrSrSr\R \R"\R5\ \R"\ 5\ \R"\ 5\\R"\R"\550rSrg)QueueInfoExternalz6Describes all of the queue entries for an application.r#N)r$r%r&r'r(r APPLICATIONrr0APPLICATION_RE_STRINGTOTAL_STORAGE_LIMIT_TOTAL_STORAGE_LIMIT_REGEXRESUME_PAUSED_QUEUES_RESUME_PAUSED_QUEUESQUEUErLr@r8r)r#r*r+rPrPse> :..w/L/LM:../IJJ//0EF Z !4!4Z!@ A *r*rPcB[R"[5n[R"U5n[ R "U5nURU5 UR5n[U5S:a [S5e[U5S:a [S5eUS$)zLoads a `queue.yaml` file/string and returns a `QueueInfoExternal` object. Args: queue_info: The contents of a `queue.yaml` file, as a string. open_fn: Function for opening files. Unused. Returns: A `QueueInfoExternal` object. zEmpty queue configuration.z*Multiple queue: sections in configuration.r) r ObjectBuilderrPr BuilderHandlerr EventListenerParse GetResultslenr!) queue_infoopen_fnbuilderhandlerlisteners r+LoadSingleQueuerfs  % %&7 8'  ' ' 0'  ( ( 1( ..!!#*_q %&B CC_q %': ;; Ar*cXUS:XagURS5n[U5S:wa[SU-5eUup#[U5nUS ;a[SU<SU<S 35eUS :XaU$US :XaUS - $US:XaUS- $US:XaUS- $g![a [SU<SU<S35ef=f)aJParses a rate string in the form `number/unit`, or the literal `0`. The unit is one of `s` (seconds), `m` (minutes), `h` (hours) or `d` (days). Args: rate: The string that contains the rate. Returns: A floating point number that represents the `rate/second`. Raises: MalformedQueueConfiguration: If the rate is invalid. 0g/zRate "%s" is invalid.zRate "z" is invalid: "z" is not a number.smhdz" is not one of s, m, h, d.sm<hdQN)splitr`r!float ValueError)relementsnumberunits r+ ParseRaterys S[  ZZ_(]a %&=&D EE,&: 6]F   %+/'7 88 S[ M S[ "9 S[ 7  S[ <   : %+/'9 :::s B B)cUR5nU(d [S5eUS[;a7[USS5n[HnUSU:waUS-nM[ U5s $ g[ U5$![ a [SU-5ef=f)aParses a string representing the storage bytes limit. Optional limit suffixes are: - `B` (bytes) - `K` (kilobytes) - `M` (megabytes) - `G` (gigabytes) - `T` (terabytes) Args: limit: The string that specifies the storage bytes limit. Returns: An integer that represents the storage limit in bytes. Raises: MalformedQueueConfiguration: If the limit argument isn't a valid Python double followed by an optional suffix. z&Total Storage Limit must not be empty.riz$Total Storage Limit "%s" is invalid.N)stripr! BYTE_SUFFIXESrtintru)limitrwcs r+ParseTotalStorageLimitrs( ++-%  %&N OO- RyM!U1R[!f! 9>D=&V  Z - %&L&+', ---sAA3%A3( A33B cdUR5nU(d [S5eUSnUS;a [S5e[USS5nUS:Xa [U5$US:Xa[US-5$US :Xa[US -5$US :Xa[US -5$g![a [S U-5ef=f)aParses a string representing the task's age limit (maximum allowed age). The string must be a non-negative integer or floating point number followed by one of `s`, `m`, `h`, or `d` (seconds, minutes, hours, or days, respectively). Args: age_limit: The string that contains the task age limit. Returns: An integer that represents the age limit in seconds. Raises: MalformedQueueConfiguration: If the limit argument isn't a valid Python double followed by a required suffix. z!Task Age Limit must not be empty.r{rkzJTask Age_Limit must be in s (seconds), m (minutes), h (hours), or d (days)rrlrmrnrorprqrrzTask Age_Limit "%s" is invalid.N)r|r!rtr~ru) age_limitrxrws r+ParseTaskAgeLimitrs oo)  %&I JJ 2$  %'L MM 1 9Qr? #F s{ [ s{ "  s{ $  s{ %   1 %&G&/'0 111sBB-BBB/c|[R"5nURb$UR[ UR55 UR b$UR [UR 55 URb$UR[UR55 URb$UR[UR55 URb$UR[ UR55 UR5(aVUR!5(dAUR#5UR%5:aURUR#55 UR5(dVUR!5(aAUR#5UR%5:aURUR%55 UR'5(aUR)5S:a [+S5eUR-5(aUR/5S:d [+S5eUR5(aUR#5S:a [+S5eUR!5(aUR%5S:a [+S5eUR15(aUR5S:a [+S5eUR5(aBUR!5(a-UR#5UR%5:a [+S5eU$)aPopulates a `TaskQueueRetryParameters` from a `queueinfo.RetryParameters`. Args: retry: A `queueinfo.RetryParameters` that is read from `queue.yaml` that describes the queue's retry parameters. Returns: A `taskqueue_service_pb.TaskQueueRetryParameters` proto populated with the data from `retry`. Raises: MalformedQueueConfiguration: If the retry parameters are invalid. rz,Task retry limit must not be less than zero.z)Task age limit must be greater than zero.z/Min backoff seconds must not be less than zero.z/Max backoff seconds must not be less than zero.z)Max doublings must not be less than zero.z>Min backoff sec must not be greater than than max backoff sec.)r TaskQueueRetryParametersrset_retry_limitr~rset_age_limit_secrrset_min_backoff_secrtrset_max_backoff_secrset_max_doublingshas_min_backoff_sechas_max_backoff_secmin_backoff_secmax_backoff_sechas_retry_limit retry_limitr!has_age_limit_sec age_limit_sechas_max_doublings)retryparamss r+TranslateRetryParametersr"s 8 8 :& ' 3u5567 % .u/C/CDE * uU%>%>?@ * uU%>%>?@ $ S!4!456  !!&*D*D*F*F &"8"8"::   !7!7!9:  # # % %&*D*D*F*F &"8"8"::   !7!7!9: &"4"4"6": %6 88 (<(<(>(B %3 55 !!f&<&<&>&B %9 ;; !!f&<&<&>&B %9 ;; F$8$8$:Q$> %3 55   ""v'A'A'C'C !7!7!99 %H JJ -r*)N)9r( __future__rr __author__osenvirongetgoogle.appengine.apirrr r r google.appengine.api.taskqueuer googlecloudsdk.appengine.api&googlecloudsdk.appengine.api.taskqueuerCrErUrWrGMODULE_ID_RE_STRINGMODULE_VERSION_RE_STRINGrNrXrBrDrHrFrMrIrTrVr}rJr/r2r4r6r7rKr<r> Exceptionr! Validatedr-r:r@rPrfryrrrr#r*r+rsp '' .  ::>>%&*4*-/0.A25786I' . <* .4-E,?A      3+- %%!++     @)@j***   %%   ,,0%!P%-P$1NAr*