5HSrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r S r "S S \ R5r"S S \ R5r"SS\ R5rSrSrSrSrSrSrSrSrSrSrSrSrSrS"SjrSr S r!S!r"g)#z,Utilities for Data Catalog crawler commands.)absolute_import)division)unicode_literals)crawlers) arg_utils)repeated) exceptionsv1alpha3c\rSrSrSrSrg)InvalidCrawlScopeErrorz"Error if a crawl scope is invalid.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__rzArguments `--add-buckets`, `--remove-buckets`, and `--clear-buckets` are only valid for bucket-scoped crawlers. Use `--crawl-scope=bucket` to specify a bucket-scoped crawler.z_Must provide buckets to add or remove when updating the crawl scope of a bucket-scoped crawler.)_IsChangeBucketsSpecifiedr>r5r"r3 bucketScoper )r(r)r*r,change_bucketss rr#r#s ,T2.))X5  &&{{}''/  . // D,,8  & '' .rcA/nURS5(aURS5 URS5(aURS5 [U5(aURS5 URS:XaURS5 OCURS:XaURS5 O![ U5(aURS 5 UR S :XaURS 5 O7UR S :XdURS 5(aURS5 U(d [ S5eSRU5UlU$)a9Python hook that computes the update mask for a patch request. Args: ref: The crawler resource reference. args: The parsed args namespace. request: The update crawler request. Returns: Request with update mask set appropriately. Raises: NoFieldsSpecifiedError: If no fields were provided for updating. description display_name displayNamezconfig.bundleSpecsprojectzconfig.projectScope organizationzconfig.organizationScopezconfig.bucketScopemanualzconfig.adHocRun scheduled run_schedulezconfig.scheduledRunz.Must specify at least one parameter to update.,) r5appendr2r>rB run_optionrjoin updateMask)r(r)r* update_masks r SetUpdateMaskrTs) + m$$}% n%%}%"4((+, ",- >)12 &&+, __ () +%)9)9.)I)I,-  8 ::xx ,' .rcA[R"5nURnURS5(a*URVs/sHnUR US9PM nnOSn[ URXbU5$s snf)zPython hook that parses the crawl scope args into the create request. Args: ref: The crawler resource reference. args: The parsed args namespace. request: The create crawler request. Returns: Request with crawl scope set appropriately. r<r=N)rrmessagesr5r<(GoogleCloudDatacatalogV1alpha3BucketSpec_SetScopeInRequestr>)r(r)r*r+rWr:r<s rParseScopeFlagsForCreaterZs  " " $& __( i   &$1@@@J$ &GG D,,g II &sA<cA[R"5nURn[U5(a[ XU5nSnOSnUR n[ XvX%5$)a)Python hook that parses the crawl scope args into the update request. Args: ref: The crawler resource reference. args: The parsed args namespace. request: The update crawler request. crawler: CachedResult, The cached crawler result. Returns: Request with crawl scope set appropriately. r=N)rrrWrB_GetBucketsPatchr>rY)r(r)r*r,r+rWr<r>s rr%r%sY  " " $& __(t$$th7GKG""K K' DDrcURS5=(d) URS5=(d URS5$)N add_bucketsremove_buckets clear_bucketsr5r)s rrBrBs<   = ) ,   + , ,   ? +-rcURS5=(d) URS5=(d URS5$)Nr1r0r/rarbs rr2r2s>   - . 1   0 1 1   / 02rcUS:Xa,U(d [S5e[R"USU5 U$US:Xa([R"USUR55 U$US:Xa&[R"USUR 55 U$)z)Returns request with the crawl scope set.r=zSAt least one bucket must be included in the crawl scope of a bucket-scoped crawler.z@googleCloudDatacatalogV1alpha3Crawler.config.bucketScope.bucketsrIz9googleCloudDatacatalogV1alpha3Crawler.config.projectScoperJz>googleCloudDatacatalogV1alpha3Crawler.config.organizationScope)r rr70GoogleCloudDatacatalogV1alpha3ParentProjectScope5GoogleCloudDatacatalogV1alpha3ParentOrganizationScope)r>r<r*rWs rrYrYsH  " # $$J .i CAACE . n$ HFFHJ .rcUR5RRnU(a URO/nUR S5(a/nUR S5(a8[ UR 5nUVs/sHofRU;dMUPM nnUR S5(a-UURVs/sHnURUS9PM sn- nU$s snfs snf)zReturns list of buckets for a patch request based on the args provided. Args: args: The parsed args namespace. crawler: CachedResult, The cached crawler result. messages: The messages module. Returns: Desired list of buckets. r`r_r^rV) r"r3rCr<r5r6r_r=r^rX)r)r,rW bucket_scoper<r9r:s rr\r\s%%11,$0L b' o&&G &''D''(I!?'QXXY%>q'G? m$$ ))+)AAAAK)++G . @+sC%C%C*cA[X5$N_ValidateSchedulingFlagsr?s r ValidateSchedulingFlagsForCreaterm7s !$ 00rcA[XUSS9$)NT) for_updaterk)r(r)r*r,s rr$r$<s !$T JJrNcNURS:Xa!URS5(d [S5eURS:wacURS5(aMU(a;URS5(d%UR5RR c [S5eU$)arValidates scheduling flags. Args: args: The parsed args namespace. request: The create or update request. crawler: CachedResult, The cached crawler result. for_update: If the request is for update instead of create. Returns: The request, if the scheduling configuration is valid. Raises: InvalidRunOptionError: If the scheduling configuration is not valid. rLrMzUArgument `--run-schedule` must be provided if `--run-option=scheduled` was specified.rPzArgument `--run-schedule` can only be provided for scheduled crawlers. Use `--run-option=scheduled` to specify a scheduled crawler.)rPr5rr"r3 scheduledRun)r)r*r,ros rrlrlAs __ #D,<,<^,L,L    __ #(8(8(H(H  && ))1 !   .rcA[R"5nURn[URUR X$5$rj)rrrW_SetRunOptionInRequestrPrM)r(r)r*r+rWs rParseSchedulingFlagsForCreatertbs:  " " $& __(  oot((' ==rcA[R"5nURnURS5(aSO URn[ XQR X$5$)NrMrL)rrrWr5rPrsrM)r(r)r*r+rWrPs rr&r&jsU  " " $& __( $//?? __ ##W 88rcUS:Xa([R"USUR55 U$US:XaC[R"UURR 5n[R"USU5 U$)z(Returns request with the run option set.rKz5googleCloudDatacatalogV1alpha3Crawler.config.adHocRunrLzLgoogleCloudDatacatalogV1alpha3Crawler.config.scheduledRun.scheduledRunOption)rr7&GoogleCloudDatacatalogV1alpha3AdhocRun ChoiceToEnum*GoogleCloudDatacatalogV1alpha3ScheduledRun!ScheduledRunOptionValueValuesEnum)rPrMr*rWscheduled_run_options rrsrsws~8 ?779; .[ $11  < < + +.V .r)NF)#r __future__rrr#googlecloudsdk.api_lib.data_catalogr$googlecloudsdk.command_lib.util.apisr$googlecloudsdk.command_lib.util.argsrgooglecloudsdk.corer DATACATALOG_CRAWLER_API_VERSIONErrorr rrr-r'r@r#rTrZr%rBr2rYr\rmr$rlrtr&rsrrrrs3&'8:9*",+Z--+*J,,*>Z-->@>0<(VJ*E8- 2 201 K B= 8r