zHSrSSKJr SSKJr SSKJr SSKJr Sr "SS\R5r "S S \R5r "S S \R5r "S S\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS \R5r"S!S"\R5r"S#S$\R5r"S%S&\R5r"S'S(\R5r"S)S*\R5r"S+S,\R5r"S-S.\R5r"S/S0\R5r"S1S2\R5r "S3S4\R5r!"S5S6\R5r""S7S8\R5r#"S9S:\R5r$"S;S<\R5r%"S=S>\R5r&"S?S@\R5r'"SASB\R5r("SCSD\R5r)"SESF\R5r*"SGSH\R5r+"SISJ\R5r,"SKSL\R5r-"SMSN\R5r."SOSP\R5r/"SQSR\R5r0"SSST\R5r1"SUSV\R5r2"SWSX\R5r3"SYSZ\R5r4"S[S\\R5r5"S]S^\R5r6"S_S`\R5r7"SaSb\R5r8"ScSd\R5r9"SeSf\R5r:"SgSh\R5r;"SiSj\R5r<"SkSl\R5r="SmSn\R5r>"SoSp\R5r?"SqSr\R5r@"SsSt\R5rA"SuSv\R5rB"SwSx\R5rC"SySz\R5rD"S{S|\R5rE"S}S~\R5rF"SS\R5rG"SS\R5rH"SS\R5rI"SS\R5rJ"SS\R5rK"SS\R5rL"SS\R5rM"SS\R5rN"SS\R5rO"SS\R5rP"SS\R5rQ"SS\R5rR"SS\R5rS"SS\R5rT"SS\R5rU"SS\R5rV"SS\R5rW"SS\R5rX"SS\R5rY"SS\R5rZ"SS\R5r["SS\R5r\"SS\R5r]"SS\R5r^"SS\R5r_"SS\R5r`"SS\R5ra"SS\R5rb"SS\R5rc"SS\R5rd"SS\R5re"SS\R5rf"SS\R5rg"SS\R5rh"SS\R5ri"SS\R5rj"SS\R5rk"SS\R5rl"SS\R5rm"SS\R5rn"SS\R5ro"SS\R5rp"SS\R5rq"SS\R5rr"SS\R5rs"SS\R5rt"SS\R5ru"SS\R5rv"SS\R5rw"SS\R5rx"SS\R5ry"SS\R5rz"SS\R5r{"SS\R5r|"SS\R5r}"SS\R5r~"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SGS\R5r"GSGS\R5r\GR"\xGSGS5 \GR"\xGRGSGS5 \GR"\xGRGSGS5 \GR"\GS GS 5 \GR"\GS GS 5 Gg (zxGenerated message classes for composer version v1alpha2. Manages Apache Airflow environments on Google Cloud Platform. )absolute_import)messages)encoding) extra_typescomposerc\rSrSrSrSrg)ActivateDagRequestzRequest to unpause a DAG.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r Ylib/googlecloudsdk/generated_clients/apis/composer/v1alpha2/composer_v1alpha2_messages.pyr r s"rr c\rSrSrSr"SS\R 5r\R"S\RRS9r \R"SS5r Srg ) $AirflowMetadataRetentionPolicyConfiga.The policy for airflow metadata database retention. Enums: RetentionModeValueValuesEnum: Optional. Retention can be either enabled or disabled. Fields: retentionDays: Optional. How many days data should be retained for. retentionMode: Optional. Retention can be either enabled or disabled. c$\rSrSrSrSrSrSrSrg)AAirflowMetadataRetentionPolicyConfig.RetentionModeValueValuesEnum!aOptional. Retention can be either enabled or disabled. Values: RETENTION_MODE_UNSPECIFIED: Default mode doesn't change environment parameters. RETENTION_MODE_ENABLED: Retention policy is enabled. RETENTION_MODE_DISABLED: Retention policy is disabled. rr N) r rrrrRETENTION_MODE_UNSPECIFIEDRETENTION_MODE_ENABLEDRETENTION_MODE_DISABLEDrr rrRetentionModeValueValuesEnumr!s"#rr rvariantrr N)r rrrr _messagesEnumr IntegerFieldVariantINT32 retentionDays EnumField retentionModerr rrrrsJ   Y^^  ((I4E4E4K4KL-%%&DaH-rrc`\rSrSrSr\R "S5r\R "S5rSr g)AllowedIpRange2a:Allowed IP range with user-provided description. Fields: description: Optional. User-provided description. It must contain at most 300 characters. value: IP address or range, defined using CIDR notation, of requests that this rule applies to. Examples: `192.168.1.1` or `192.168.0.0/16` or `2001:db8::/32` or `2001:0db8:0000:0042:0000:8a2e:0370:7334`. IP range prefixes should be properly truncated. For example, `1.2.3.4/24` should be truncated to `1.2.3.0/24`. Similarly, for IPv6, `2001:db8::1/32` should be truncated to `2001:db8::/32`. rrr N) r rrrrr# StringField descriptionvaluerr rrr,r,2s) %%a(+    "%rr,c\rSrSrSrSrg)CancelOperationRequestDz3The request message for Operations.CancelOperation.r Nr r rrr2r2Ds>  !!"89Zi//Z:Z4%%a(+**+;QN/ ) 3 34`bc d&&q), ) 5 5a 8++,CQGrr9c`\rSrSrSr\R "S5r\R "S5rSr g) CidrBlockzCIDR block with an optional name. Fields: cidrBlock: CIDR block that must be specified in CIDR notation. displayName: User-defined name that identifies the CIDR block. rrr N) r rrrrr#r. cidrBlock displayNamerr rrr`r`s)##A&)%%a(+rr`c<\rSrSrSr\R "S5rSrg)CloudDataLineageIntegrationzConfiguration for Cloud Data Lineage integration. Fields: enabled: Optional. Whether or not Cloud Data Lineage integration is enabled. rr N) r rrrrr# BooleanFieldenabledrr rrreres  " "1 %'rrec`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) 8ComposerProjectsLocationsEnvironmentsCheckUpgradeRequestaSA ComposerProjectsLocationsEnvironmentsCheckUpgradeRequest object. Fields: checkUpgradeRequest: A CheckUpgradeRequest resource to be passed as the request body. environment: The resource name of the environment to check upgrade for, in the form: "projects/{projectId}/locations/{locationId}/environments/{env ironmentId}" r5rrTrequiredr N) r rrrrr#rQcheckUpgradeRequestr. environmentrr rrrjrjs/"../DaH%%a$7+rrjc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) 2ComposerProjectsLocationsEnvironmentsCreateRequestzA ComposerProjectsLocationsEnvironmentsCreateRequest object. Fields: environment: A Environment resource to be passed as the request body. parent: The parent must be of the form "projects/{projectId}/locations/{locationId}". EnvironmentrrTrlr N) r rrrrr#rQror.parentrr rrrqrqs-&&}a8+  T 2&rrqc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) 8ComposerProjectsLocationsEnvironmentsDagsActivateRequestzA ComposerProjectsLocationsEnvironmentsDagsActivateRequest object. Fields: activateDagRequest: A ActivateDagRequest resource to be passed as the request body. name: Required. The name of dag to pause. r rrTrlr N) r rrrrr#rQactivateDagRequestr.namerr rrrvrvs/!--.BAF   q4 0$rrvc:\rSrSrSr\R "SSS9rSrg):ComposerProjectsLocationsEnvironmentsDagsDagRunsGetRequestaA ComposerProjectsLocationsEnvironmentsDagsDagRunsGetRequest object. Fields: name: Required. The resource name of the DAG to retrieve. Must be in the form: "projects/{projectId}/locations/{locationId}/environments/{environ mentId}/dags/{dagId}/dagRuns/{dagRunId}". rTrlr N r rrrrr#r.ryrr rrr{r{   q4 0$rr{c\rSrSrSr\R "S5r\R"S\RRS9r \R "S5r \R "SSS 9r \R"S \RRS9rS rg ) ;ComposerProjectsLocationsEnvironmentsDagsDagRunsListRequestaA ComposerProjectsLocationsEnvironmentsDagsDagRunsListRequest object. Fields: filter: An expression for filtering the results. For example: executionDate<="2022-02-22T22:22:00Z" pageSize: The maximum number of DAG runs to return. pageToken: The next_page_token returned from a previous List request. parent: Required. List DAG runs in the given parent resource. Parent must be in the form: "projects/{projectId}/locations/{locationId}/environment s/{environmentId}/dags/{dagId}". If dagId is specified as a wildcard '-', the response will contain the runs of all DAGs. runsCountPerDag: Optional. If set to value greater than 0, the cross-DAG list mode will be used and response will contain the specified number of last DAG runs for selected DAGs. Pagination is not supported if this field is set. Sort order is descending by DAG run execution_date if this field is set. Filter is supported. rrr!rUrVTrlrWr N)r rrrrr#r.filterr%r&r'pageSize pageTokenrtrunsCountPerDagrr rrrrsw$   #&  # #Ay/@/@/F/F G(##A&)  T 2&**1i6G6G6M6MN/rrc:\rSrSrSr\R "SSS9rSrg)GComposerProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesGetRequestia[A ComposerProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesGetRequest object. Fields: name: Required. The resource name of the task instance to retrieve. Must be in the form: "projects/{projectId}/locations/{locationId}/environment s/{environmentId}/dags/{dagId}/dagRuns/{dagRunId}/taskInstances/{taskIdW ithOptionalMapIndex}". rTrlr Nr}r rrrrs    q4 0$rrc\rSrSrSr\R "S5r\R"S\RRS9r \R "S5r \R "SSS 9r S rg ) HComposerProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesListRequesti%aA ComposerProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesListRequest object. Fields: filter: An expression for filtering the results. For example: executionDate<="2022-02-22T22:22:00Z" pageSize: The maximum number of tasks to return. pageToken: The next_page_token returned from a previous List request. parent: Required. List task instances in the given parent DAG run. Parent must be in the form: "projects/{projectId}/locations/{locationId}/enviro nments/{environmentId}/dags/{dagId}/dagRuns/{dagRunId}". rrr!rUrVTrlr Nr rrrrr#r.rr%r&r'rrrtrr rrrr%sY    #&  # #Ay/@/@/F/F G(##A&)  T 2&rrc:\rSrSrSr\R "SSS9rSrg)3ComposerProjectsLocationsEnvironmentsDagsGetRequesti:zA ComposerProjectsLocationsEnvironmentsDagsGetRequest object. Fields: name: Required. The resource name of the DAG to retrieve. Must be in the form: "projects/{projectId}/locations/{locationId}/environments/{environ mentId}/dags/{dagId}". rTrlr Nr}r rrrr:r~rrc:\rSrSrSr\R "SSS9rSrg)=ComposerProjectsLocationsEnvironmentsDagsGetSourceCodeRequestiFaA ComposerProjectsLocationsEnvironmentsDagsGetSourceCodeRequest object. Fields: dag: Required. The resource name of the DAG to fetch source code of. Must be in the form: "projects/{projectId}/locations/{locationId}/environment s/{environmentId}/dags/{dagId}". rTrlr N) r rrrrr#r.dagrr rrrrFs a$/#rrc\rSrSrSr\R "S\RRS9r \R"S5r \R"SSS9r S r g ) 4ComposerProjectsLocationsEnvironmentsDagsListRequestiRaoA ComposerProjectsLocationsEnvironmentsDagsListRequest object. Fields: pageSize: The maximum number of DAGs to return. pageToken: The next_page_token returned from a previous List request. parent: Required. List DAGs in the given parent resource. Parent must be in the form: "projects/{projectId}/locations/{locationId}/environments/{ environmentId}". rr!rrUTrlr Nr rrrrr#r%r&r'rr.rrtrr rrrrRI # #Ay/@/@/F/F G(##A&)  T 2&rrc\rSrSrSr\R "SSS9r\R "S5r\R "S5r \R"S\RRS 9r \R "S 5rS rg ) 9ComposerProjectsLocationsEnvironmentsDagsListStatsRequestibaA ComposerProjectsLocationsEnvironmentsDagsListStatsRequest object. Fields: environment: Required. List DAGs in the given Composer environment. Parent must be in the form: "projects/{projectId}/locations/{locationId}/enviro nments/{environmentId}". interval_endTime: Optional. Exclusive end of the interval. If specified, a Timestamp matching this interval will have to be before the end. interval_startTime: Optional. Inclusive start of the interval. If specified, a Timestamp matching this interval will have to be the same or after the start. pageSize: The maximum number of DAGs to return. pageToken: The next_page_token returned from a previous List request. rTrlrrUrVr!rWr N)r rrrrr#r.rointerval_endTimeinterval_startTimer%r&r'rrrr rrrrbsk %%a$7+**1- ,,Q/  # #Ay/@/@/F/F G(##A&)rrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) 5ComposerProjectsLocationsEnvironmentsDagsPauseRequestiyzA ComposerProjectsLocationsEnvironmentsDagsPauseRequest object. Fields: name: Required. The name of dag to pause. pauseDagRequest: A PauseDagRequest resource to be passed as the request body. rTrlPauseDagRequestrr N) r rrrrr#r.ryrQpauseDagRequestrr rrrrys.   q4 0$**+ComposerProjectsLocationsEnvironmentsPollAirflowCommandRequestiaOA ComposerProjectsLocationsEnvironmentsPollAirflowCommandRequest object. Fields: environment: The resource name of the environment in the form: "projects/{projectId}/locations/{locationId}/environments/{environmentId }" pollAirflowCommandRequest: A PollAirflowCommandRequest resource to be passed as the request body. rTrlPollAirflowCommandRequestrr N) r rrrrr#r.rorQpollAirflowCommandRequestrr rrrrs0%%a$7+'445PRSTrrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) ComposerProjectsLocationsEnvironmentsStopAirflowCommandRequestiaLA ComposerProjectsLocationsEnvironmentsStopAirflowCommandRequest object. Fields: environment: The resource name of the environment in the form: "projects/{ projectId}/locations/{locationId}/environments/{environmentId}". stopAirflowCommandRequest: A StopAirflowCommandRequest resource to be passed as the request body. rTrlStopAirflowCommandRequestrr N) r rrrrr#r.rorQstopAirflowCommandRequestrr rrrrs0%%a$7+'445PRSTrrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) IComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateRequestiadA ComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateRequest object. Fields: parent: Required. The environment name to create a ConfigMap for, in the form: "projects/{projectId}/locations/{locationId}/environments/{environ mentId}" userWorkloadsConfigMap: A UserWorkloadsConfigMap resource to be passed as the request body. rTrlUserWorkloadsConfigMaprr N) r rrrrr#r.rtrQuserWorkloadsConfigMaprr rrrrs/   T 2&$112JANrrc:\rSrSrSr\R "SSS9rSrg)IComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteRequestiaA ComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteRequest object. Fields: name: Required. The ConfigMap to delete, in the form: "projects/{projectId }/locations/{locationId}/environments/{environmentId}/userWorkloadsConfi gMaps/{userWorkloadsConfigMapId}" rTrlr Nr}r rrrrs   q4 0$rrc:\rSrSrSr\R "SSS9rSrg)FComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetRequestia,A ComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetRequest object. Fields: name: Required. The resource name of the ConfigMap to get, in the form: "p rojects/{projectId}/locations/{locationId}/environments/{environmentId}/ userWorkloadsConfigMaps/{userWorkloadsConfigMapId}" rTrlr Nr}r rrrr   q4 0$rrc\rSrSrSr\R "S\RRS9r \R"S5r \R"SSS9r S r g ) GComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListRequestiaA ComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListRequest object. Fields: pageSize: Optional. The maximum number of ConfigMaps to return. pageToken: Optional. The next_page_token value returned from a previous List request, if any. parent: Required. List ConfigMaps in the given environment, in the form: "projects/{projectId}/locations/{locationId}/environments/{environmentId }" rr!rrUTrlr Nrr rrrrsI  # #Ay/@/@/F/F G(##A&)  T 2&rrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) FComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateRequestiaXA ComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateRequest object. Fields: parent: Required. The environment name to create a Secret for, in the form: "projects/{projectId}/locations/{locationId}/environments/{environ mentId}" userWorkloadsSecret: A UserWorkloadsSecret resource to be passed as the request body. rTrlUserWorkloadsSecretrr N) r rrrrr#r.rtrQuserWorkloadsSecretrr rrrrs/   T 2&!../DaHrrc:\rSrSrSr\R "SSS9rSrg)FComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteRequesti!aA ComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteRequest object. Fields: name: Required. The Secret to delete, in the form: "projects/{projectId}/l ocations/{locationId}/environments/{environmentId}/userWorkloadsSecrets/ {userWorkloadsSecretId}" rTrlr Nr}r rrrr!rrrc:\rSrSrSr\R "SSS9rSrg)CComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsGetRequesti.a A ComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsGetRequest object. Fields: name: Required. The resource name of the Secret to get, in the form: "proj ects/{projectId}/locations/{locationId}/environments/{environmentId}/use rWorkloadsSecrets/{userWorkloadsSecretId}" rTrlr Nr}r rrrr.rrrc\rSrSrSr\R "S\RRS9r \R"S5r \R"SSS9r S r g ) DComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsListRequesti;aA ComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsListRequest object. Fields: pageSize: Optional. The maximum number of Secrets to return. pageToken: Optional. The next_page_token value returned from a previous List request, if any. parent: Required. List Secrets in the given environment, in the form: "projects/{projectId}/locations/{locationId}/environments/{environmentId }" rr!rrUTrlr Nrr rrrr;sI  # #Ay/@/@/F/F G(##A&)  T 2&rrc\rSrSrSr\R "S5r\R"S\RRS9r \R "S5r \R "SSS 9r S rg ) 9ComposerProjectsLocationsEnvironmentsWorkloadsListRequestiMaA ComposerProjectsLocationsEnvironmentsWorkloadsListRequest object. Fields: filter: Optional. The list filter. Currently only supports equality on the type field. The value of a field specified in the filter expression must be one ComposerWorkloadType enum option. It's possible to get multiple types using "OR" operator, e.g.: "type=SCHEDULER OR type=CELERY_WORKER". If not specified, all items are returned. pageSize: Optional. The maximum number of environments to return. pageToken: Optional. The next_page_token value returned from a previous List request, if any. parent: Required. The environment name to get workloads for, in the form: "projects/{projectId}/locations/{locationId}/environments/{environmentId }" rrr!rUrVTrlr Nrr rrrrMsY   #&  # #Ay/@/@/F/F G(##A&)  T 2&rrc\rSrSrSr\R "S5r\R"S\RRS9r \R"S5r \R"SSS 9rS rg ) 1ComposerProjectsLocationsImageVersionsListRequestidaA ComposerProjectsLocationsImageVersionsListRequest object. Fields: includePastReleases: Whether or not image versions from old releases should be included. pageSize: The maximum number of image_versions to return. pageToken: The next_page_token value returned from a previous List request, if any. parent: List ImageVersions in the given project and location, in the form: "projects/{projectId}/locations/{locationId}" rrr!rUrVTrlr N)r rrrrr#rgincludePastReleasesr%r&r'rr.rrtrr rrrrdsZ "..q1  # #Ay/@/@/F/F G(##A&)  T 2&rrc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) 0ComposerProjectsLocationsOperationsCancelRequestiwzA ComposerProjectsLocationsOperationsCancelRequest object. Fields: cancelOperationRequest: A CancelOperationRequest resource to be passed as the request body. name: The name of the operation resource to be cancelled. r2rrTrlr N) r rrrrr#rQcancelOperationRequestr.ryrr rrrrws/%112JAN   q4 0$rrc:\rSrSrSr\R "SSS9rSrg)0ComposerProjectsLocationsOperationsDeleteRequestiz~A ComposerProjectsLocationsOperationsDeleteRequest object. Fields: name: The name of the operation resource to be deleted. rTrlr Nr}r rrrr   q4 0$rrc:\rSrSrSr\R "SSS9rSrg)-ComposerProjectsLocationsOperationsGetRequestizmA ComposerProjectsLocationsOperationsGetRequest object. Fields: name: The name of the operation resource. rTrlr Nr}r rrrrrrrc\rSrSrSr\R "S5r\R "SSS9r\R"S\RRS9r \R "S 5r \R"S 5rS rg ) .ComposerProjectsLocationsOperationsListRequestiaA ComposerProjectsLocationsOperationsListRequest object. Fields: filter: The standard list filter. name: The name of the operation's parent resource. pageSize: The standard list page size. pageToken: The standard list page token. returnPartialSuccess: When set to `true`, operations that are reachable are returned as normal, and those that are unreachable are returned in the [ListOperationsResponse.unreachable] field. This can only be `true` when reading across collections e.g. when `parent` is set to `"projects/example/locations/-"`. This field is not by default supported and will result in an `UNIMPLEMENTED` error if set unless explicitly documented otherwise in service or product specific documentation. rrTrlrUr!rVrWr N)r rrrrr#r.rryr%r&r'rrrgreturnPartialSuccessrr rrrrsj   #&   q4 0$  # #Ay/@/@/F/F G(##A&)"//2rrc\rSrSrSr"SS\R 5r\R"S5r \R"SS5r \R"SS5r S rg ) ComposerWorkloadizInformation about a single workload. Enums: TypeValueValuesEnum: Type of a workload. Fields: name: Name of a workload. status: Output only. Status of a workload. type: Type of a workload. c<\rSrSrSrSrSrSrSrSr Sr S r S r S r S rg )$ComposerWorkload.TypeValueValuesEnumiaType of a workload. Values: COMPOSER_WORKLOAD_TYPE_UNSPECIFIED: Not able to determine the type of the workload. CELERY_WORKER: Celery worker. KUBERNETES_WORKER: Kubernetes worker. KUBERNETES_OPERATOR_POD: Workload created by Kubernetes Pod Operator. SCHEDULER: Airflow scheduler. DAG_PROCESSOR: Airflow Dag processor. TRIGGERER: Airflow triggerer. WEB_SERVER: Airflow web server UI. REDIS: Redis. rrrrUrVrWrXr N)r rrrr"COMPOSER_WORKLOAD_TYPE_UNSPECIFIED CELERY_WORKERKUBERNETES_WORKERKUBERNETES_OPERATOR_POD SCHEDULER DAG_PROCESSOR TRIGGERER WEB_SERVERREDISrr rrTypeValueValuesEnumrs9 *+&MIMIJ ErrrComposerWorkloadStatusrrUr N)r rrrrr#r$rr.ryrQstatusr)typerr rrrrsO INN2   q !$  ! !":A >&   2A 6$rrc\rSrSrSr"SS\R 5r\R"S5r \R"SS5r \R"S5r Sr g ) ria Workload status. Enums: StateValueValuesEnum: Output only. Workload state. Fields: detailedStatusMessage: Output only. Detailed message of the status. state: Output only. Workload state. statusMessage: Output only. Text to provide more descriptive status. c4\rSrSrSrSrSrSrSrSr Sr S r S r g ) +ComposerWorkloadStatus.StateValueValuesEnumiaOutput only. Workload state. Values: COMPOSER_WORKLOAD_STATE_UNSPECIFIED: Not able to determine the status of the workload. PENDING: Workload is in pending state and has not yet started. OK: Workload is running fine. WARNING: Workload is running but there are some non-critical problems. ERROR: Workload is not running due to an error. SUCCEEDED: Workload has finished execution with success. FAILED: Workload has finished execution with failure. rrrrUrVrWrXr N) r rrrr#COMPOSER_WORKLOAD_STATE_UNSPECIFIEDPENDINGOKWARNINGERROR SUCCEEDEDFAILEDrr rrStateValueValuesEnumr s- +,'G BG EI FrrrrrUr N)r rrrrr#r$rr.detailedStatusMessager)state statusMessagerr rrrrsM Y^^*$//2   4a 8%''*-rrc\rSrSrSr"SS\R 5r\R"S5r \R"SS5r Sr g) rTizEnvironment configuration conflict. Enums: TypeValueValuesEnum: Conflict type. It can be blocking or non-blocking. Fields: message: Conflict message. type: Conflict type. It can be blocking or non-blocking. c$\rSrSrSrSrSrSrSrg)"ConfigConflict.TypeValueValuesEnumi a*Conflict type. It can be blocking or non-blocking. Values: CONFLICT_TYPE_UNSPECIFIED: Conflict type is unknown. BLOCKING: Conflict is blocking, the upgrade would fail. NON_BLOCKING: Conflict is non-blocking. The upgrade would succeed, but the environment configuration would be changed. rrrr N) r rrrrCONFLICT_TYPE_UNSPECIFIEDBLOCKING NON_BLOCKINGrr rrrr s!"HLrrrrr N) r rrrrr#r$rr.messager)rrr rrrTrTs< INN   ! !! $'   2A 6$rrTcF\rSrSrSr"SS\R 5r"SS\R 5r\R"SS5r \R"S5r \R"S 5r \R"S 5r\R"S 5r\R"S 5r\R"S 5r\R$"S5r\R"S5r\R"S5r\R"S5r\R."S\R0R2S9r\R."S\R0R2S9r\R"S5r\R."S\R0R2S9r\R"S5r\R"SS5rSr g)Dagia@A Composer DAG resource. Enums: CatchupValueValuesEnum: Whether the catchup is enabled for the DAG. StateValueValuesEnum: Output only. The current state of the DAG. Fields: catchup: Whether the catchup is enabled for the DAG. cronSchedule: The DAG's schedule in cron format. dagId: Required. The DAG ID. dagrunTimeout: Maximum runtime of a DAG run before termination with a timeout. description: The description of the DAG. durationSchedule: The DAG's schedule as a time duration between runs. endDate: The end_date parameter of the DAG (if set). failStop: Whether a "fail_stop" mode is enabled for the DAG. fileloc: File location relative to the Cloud Storage bucket root folder. lastRunEndTime: The end timestamp of the last completed DAG run. lastUpdated: The last time the DAG has been serialized. maxActiveRuns: Maximum number of simultaneous active runs of the DAG. Default is zero. maxActiveTasks: Maximum number of simultaneous active tasks of the DAG. Default is zero. name: Required. The resource name of the DAG, in the form: "projects/{proj ectId}/locations/{locationId}/environments/{environmentId}/dags/{dagId}" . runningCount: The number of running instances of the DAG. startDate: The start_date parameter of the DAG. state: Output only. The current state of the DAG. c$\rSrSrSrSrSrSrSrg)Dag.CatchupValueValuesEnumi<zWhether the catchup is enabled for the DAG. Values: CATCHUP_VALUE_UNSPECIFIED: The state of the Cachup is unknown. ENABLED: The catchup is enabled. DISABLED: The catchup is disabled. rrrr N) r rrrrCATCHUP_VALUE_UNSPECIFIEDENABLEDDISABLEDrr rrCatchupValueValuesEnumr <s!"GHrr$c$\rSrSrSrSrSrSrSrg)Dag.StateValueValuesEnumiHzOutput only. The current state of the DAG. Values: STATE_UNSPECIFIED: The state of the DAG is unknown. ACTIVE: The DAG is available for execution. PAUSED: The DAG is paused. rrrr N) r rrrrSTATE_UNSPECIFIEDACTIVEPAUSEDrr rrrr&Hs F FrrrrrUrVrWrXrr r! r r N)!r rrrrr#r$r$rr)catchupr. cronScheduledagId dagrunTimeoutr/durationScheduleendDatergfailStopfileloclastRunEndTime lastUpdatedr%r&r' maxActiveRunsmaxActiveTasksry runningCount startDaterrr rrrrsj> y~~  Y^^     8! <'&&q),    "%''*-%%a(+**1-  ! !! $'  # #A &(  ! !! $'((,.%%b)+((Y5F5F5L5LM-))"i6G6G6M6MN.   r "$''I4E4E4K4KL,##B')   4b 9%rrc@\rSrSrSr\R "S\RRS9r \R"S\RRS9r \R"S\RRS9r \R"S\RRS9rSrg ) DagProcessorResourceigaYConfiguration for resources used by Airflow DAG processors. This field is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Fields: count: Optional. The number of DAG processors. If not provided or set to 0, a single DAG processor instance will be created. cpu: Optional. CPU request and limit for a single Airflow DAG processor replica. memoryGb: Optional. Memory (GB) request and limit for a single Airflow DAG processor replica. storageGb: Optional. Storage (GB) request and limit for a single Airflow DAG processor replica. rr!rrUrVr Nr rrrrr#r%r&r'count FloatFieldFLOATcpumemoryGb storageGbrr rrrArAgs   I,=,=,C,C D%Q (9(9(?(?@#  ! !!Y->->-D-D E(""1i.?.?.E.EF)rrAc\rSrSrSr"SS\R 5r"SS\R 5r\R"S5r \R"S5r \R"S 5r \R"S 5r \R"S 5r\R"S 5r\R"S 5r\R"S5r\R"S5r\R&"SS5r\R&"SS5rSrg)DagRuni}a[A single DAG run. Enums: StateValueValuesEnum: DAG run state. TypeValueValuesEnum: DAG run type (how it got created/executed). Fields: dagId: The DAG ID of the DAG whose execution is described by this DAG run. dagRunId: The DAG run ID. dataIntervalEnd: End of the data interval. Added in version 2.2. If run has been triggered manually, this field is equal to execution_date. dataIntervalStart: Start of the data interval. Added in version 2.2. If run has been triggered manually, this field is equal to execution_date. endDate: Timestamp when the DAG run ended. Set only if the DAG run has finished. executionDate: The logical date and time which the DAG run and its task instances are running for. name: The resource name of the DAG, in the form: "projects/{projectId}/loc ations/{locationId}/environments/{environmentId}/dags/{dagId}/dagRuns/{d agRunId}". runAfter: Timestamp when the DAG run was scheduled to start. Added in Airflow 3. startDate: Timestamp when the DAG run started. state: DAG run state. type: DAG run type (how it got created/executed). c,\rSrSrSrSrSrSrSrSr Sr g ) DagRun.StateValueValuesEnumiaDAG run state. Values: STATE_UNSPECIFIED: The state of the DAG run is unknown. RUNNING: The DAG run is being executed. SUCCEEDED: The DAG run is finished successfully. FAILED: The DAG run is finished with an error. QUEUED: The DAG run is queued for execution. rrrrUrVr N) r rrrrr'RUNNINGrrQUEUEDrr rrrrLs#GI F Frrc,\rSrSrSrSrSrSrSrSr Sr g ) DagRun.TypeValueValuesEnumizDAG run type (how it got created/executed). Values: TYPE_UNSPECIFIED: The type of the DAG run is unknown. BACKFILL: Backfill run. SCHEDULED: Scheduled run. MANUAL: Manually triggered run. DATASET_TRIGGERED: Triggered by a dataset update. rrrrUrVr N) r rrrrTYPE_UNSPECIFIEDBACKFILL SCHEDULEDMANUALDATASET_TRIGGEREDrr rrrrPs$HI FrrrrrUrVrWrXrrr*r+r,r N)r rrrrr#r$rrr.r4dagRunIddataIntervalEnddataIntervalStartr7 executionDateryrunAfterr?r)rrrr rrrJrJ}s6Y^^ INN    "%  " "1 %())!,/++A.  ! !! $'''*-   q !$  " "1 %(##A&)   4b 9%   2B 7$rrJc\rSrSrSr\R "S5r\R"S\RRS9r \R"S\RRS9r Sr g) DagStatsizStatistics of a DAG in a specific time interval. Fields: dag: DAG name. failedRunCount: Number of DAG runs finished with a failure in the time interval. successfulRunCount: Number of DAG runs successfully finished in the time interval. rrr!rUr N)r rrrrr#r.rr%r&r'failedRunCountsuccessfulRunCountrr rrr\r\sV a #))!Y5F5F5L5LM. --a9J9J9P9PQrr\cH\rSrSrSr"SS\R 5r\R"S\RRS9r \R"SS5r \R"S S 5r\R"S \RRS9r\R "SS 5rS rg)DataRetentionConfigiaHThe configuration setting for Airflow database data retention mechanism. Enums: TaskLogsStorageModeValueValuesEnum: Optional. The mode of storage for Airflow workers task logs. Fields: airflowDatabaseRetentionDays: Optional. The number of days describing for how long to store event-based records in airflow database. If the retention mechanism is enabled this value must be a positive integer otherwise, value should be set to 0. airflowMetadataRetentionConfig: Optional. The retention policy for airflow metadata database. taskLogsRetentionConfig: Optional. The configuration settings for task logs retention taskLogsRetentionDays: Optional. The number of days to retain task logs in the Cloud Logging bucket. taskLogsStorageMode: Optional. The mode of storage for Airflow workers task logs. c$\rSrSrSrSrSrSrSrg)6DataRetentionConfig.TaskLogsStorageModeValueValuesEnumiUOptional. The mode of storage for Airflow workers task logs. Values: TASK_LOGS_STORAGE_MODE_UNSPECIFIED: This configuration is not specified by the user. CLOUD_LOGGING_AND_CLOUD_STORAGE: Store task logs in Cloud Logging and in the environment's Cloud Storage bucket. CLOUD_LOGGING_ONLY: Store task logs in Cloud Logging only. rrrr N r rrrr"TASK_LOGS_STORAGE_MODE_UNSPECIFIEDCLOUD_LOGGING_AND_CLOUD_STORAGECLOUD_LOGGING_ONLYrr rr"TaskLogsStorageModeValueValuesEnumrb*+&&'#rrhrr!rrTaskLogsRetentionConfigrUrVrWr N)r rrrrr#r$rhr%r&r'airflowDatabaseRetentionDaysrQairflowMetadataRetentionConfigtaskLogsRetentionConfigtaskLogsRetentionDaysr)taskLogsStorageModerr rrr`r`s* 9>> "+!7!79CTCTCZCZ![#,#9#9:`bc#d %223LaP#00I.++,>B''(H!L/$$Q'*,,-@!D#,#9#9:Z\^#_ %%lB7*$$R1B1B1H1HI)&334NPRS))*:B?.&&'FK.))*:B?.**+'''*-rrc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) ListDagStatsResponseizResponse to `ListDagStatsRequest`. Fields: dagStats: List of DAGs with statistics. nextPageToken: The page token used to query for the next page if one exists. r\rTrMrr N) r rrrrr#rQdagStatsr.rrr rrrrs- # #JD A(''*-rrc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) ListDagsResponseizResponse to `ListDagsRequest`. Fields: dags: The list of DAGs returned. nextPageToken: The page token used to query for the next page if one exists. rrTrMrr N) r rrrrr#rQdagsr.rrr rrrrs-   q4 8$''*-rrc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) ListEnvironmentsResponseizThe environments in a project and location. Fields: environments: The list of environments returned by a ListEnvironmentsRequest. nextPageToken: The page token used to query for the next page if one exists. rsrTrMrr N) r rrrrr#rQ environmentsr.rrr rrrrs-'' q4H,''*-rrc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) ListImageVersionsResponsei!zThe ImageVersions in a project and location. Fields: imageVersions: The list of supported ImageVersions in a location. nextPageToken: The page token used to query for the next page if one exists. rrTrMrr N) r rrrrr#rQ imageVersionsr.rrr rrrr!s-((TJ-''*-rrc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) ListImportErrorsResponsei.zResponse to `ListImportErrorsRequest`. Fields: importErrors: List of DAGs with statistics. nextPageToken: The page token used to query for the next page if one exists. rrTrMrr N) r rrrrr#rQ importErrorsr.rrr rrrr.s-'' q4H,''*-rrc\rSrSrSr\R "S5r\R"SSSS9r \R "SSS9r S r g ) ListOperationsResponsei;aThe response message for Operations.ListOperations. Fields: nextPageToken: The standard List next-page token. operations: A list of operations that matches the specified filter in the request. unreachable: Unordered list. Unreachable resources. Populated when the request sets `ListOperationsRequest.return_partial_success` and reads across collections e.g. when attempting to list all resources across all supported locations. r OperationrTrMrUr N) r rrrrr#r.rrQ operations unreachablerr rrrr;s? ''*-%%k1tD*%%a$7+rrc`\rSrSrSr\R "S5r\R"SSSS9r Sr g ) ListTaskInstancesResponseiMzResponse to `ListTaskInstancesRequest`. Fields: nextPageToken: The page token used to query for the next page if one exists. taskInstances: The list of tasks returned. r TaskInstancerTrMr N) r rrrrr#r.rrQ taskInstancesrr rrr r Ms-''*-((TJ-rr c`\rSrSrSr\R "S5r\R"SSSS9r Sr g ) ListTasksResponseiZzResponse to `ListTasksRequest`. Fields: nextPageToken: The page token used to query for the next page if one exists. tasks: The list of tasks returned. rTaskrTrMr N) r rrrrr#r.rrQtasksrr rrr r Zs-''*-  T :%rr c`\rSrSrSr\R "S5r\R"SSSS9r Sr g ) #ListUserWorkloadsConfigMapsResponseigzThe user workloads ConfigMaps for a given environment. Fields: nextPageToken: The page token used to query for the next page if one exists. userWorkloadsConfigMaps: The list of ConfigMaps returned by a ListUserWorkloadsConfigMapsRequest. rrrTrMr N) r rrrrr#r.rrQuserWorkloadsConfigMapsrr rrrrgs0''*-%223KQY]^rrc`\rSrSrSr\R "S5r\R"SSSS9r Sr g ) ListUserWorkloadsSecretsResponseiuzThe user workloads Secrets for a given environment. Fields: nextPageToken: The page token used to query for the next page if one exists. userWorkloadsSecrets: The list of Secrets returned by a ListUserWorkloadsSecretsRequest. rrrTrMr N) r rrrrr#r.rrQuserWorkloadsSecretsrr rrrrus0''*-"//0EqSWXrrc`\rSrSrSr\R "S5r\R"SSSS9r Sr g ) ListWorkloadsResponseizResponse to ListWorkloadsRequest. Fields: nextPageToken: The page token used to query for the next page if one exists. workloads: The list of environment workloads. rrrTrMr N) r rrrrr#r.rrQ workloadsrr rrrrs.''*-$$%7TJ)rrc\rSrSrSr\R "S5r\R "S5r\R "S5r \R "S5r \R"S5r Sr g ) riaRequest to load a snapshot into a Cloud Composer environment. Fields: skipAirflowOverridesSetting: Whether or not to skip setting Airflow overrides when loading the environment's state. skipEnvironmentVariablesSetting: Whether or not to skip setting environment variables when loading the environment's state. skipGcsDataCopying: Whether or not to skip copying Cloud Storage data when loading the environment's state. skipPypiPackagesInstallation: Whether or not to skip installing Pypi packages when loading the environment's state. snapshotPath: A Cloud Storage path to a snapshot to load, e.g.: "gs://my- bucket/snapshots/project_location_environment_timestamp". rrrUrVrWr N)r rrrrr#rgskipAirflowOverridesSettingskipEnvironmentVariablesSettingskipGcsDataCopyingskipPypiPackagesInstallationr. snapshotPathrr rrrrs] !* 6 6q 9$-$:$:1$=! --a0!*!7!7!:&&q),rrc\rSrSrSrSrg)LoadSnapshotResponseiz Response to LoadSnapshotRequest.r Nr r rrr r s)rr c\rSrSrSr\R "S5r\R "S5r\R "S5r Sr g)riaThe configuration settings for Cloud Composer maintenance window. The following example: ``` { "startTime":"2019-08-01T01:00:00Z" "endTime":"2019-08-01T07:00:00Z" "recurrence":"FREQ=WEEKLY;BYDAY=TU,WE" } ``` would define a maintenance window between 01 and 07 hours UTC during each Tuesday and Wednesday. Fields: endTime: Required. Maintenance window end time. It is used only to calculate the duration of the maintenance window. The value for end_time must be in the future, relative to `start_time`. recurrence: Required. Maintenance window recurrence. Format is a subset of [RFC-5545](https://tools.ietf.org/html/rfc5545) `RRULE`. The only allowed values for `FREQ` field are `FREQ=DAILY` and `FREQ=WEEKLY;BYDAY=...` Example values: `FREQ=WEEKLY;BYDAY=TU,WE`, `FREQ=DAILY`. startTime: Required. Start time of the first recurrence of the maintenance window. rrrUr N) r rrrrr#r.endTime recurrence startTimerr rrrrs9&  ! !! $'$$Q'*##A&)rrc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) riaConfiguration options for the master authorized networks feature. Enabled master authorized networks will disallow all external traffic to access Kubernetes master through HTTPS except traffic from the given CIDR blocks, Google Compute Engine Public IPs and Google Prod IPs. Fields: cidrBlocks: Up to 50 external networks that could access Kubernetes master through HTTPS. enabled: Optional. Whether or not master authorized networks feature is enabled. r`rTrMrr N) r rrrrr#rQ cidrBlocksrgrhrr rrrrs- %%k1tD*  " "1 %'rrc\rSrSrSr"SS\R 5r\R"SS5r \R"S5r \R"SS5r \R"S S 5rS rg ) riaRequest to migrate a Composer 2 environment to Composer 3 in place. Enums: GkeClusterRetentionPolicyValueValuesEnum: Required. The retention policy for the GKE cluster associated with the Cloud Composer 2 environment. The cluster can be retained or deleted after the migration. Fields: gkeClusterRetentionPolicy: Required. The retention policy for the GKE cluster associated with the Cloud Composer 2 environment. The cluster can be retained or deleted after the migration. imageVersion: Required. Target image version to which the environment will be migrated. This has to be a Composer 3 version with a specific Airflow version and build in format `composer-3-airflow-x.y.z-build.t`, or one of the version aliases: `composer-3-airflow-x`, `composer-3-airflow-x.y` or `composer-3-airflow-x.y.z`. Only migration to Composer 3 version is supported. See also [version list](/composer/docs/composer-versions) and [versioning overview](/composer/docs/composer-versioning-overview). maintenanceWindow: Optional. The configuration settings for Cloud Composer maintenance window. This configuration is applied to the migrated environment. The following example: ``` { "startTime":"2019-08-01T01:00:00Z" "endTime":"2019-08-01T07:00:00Z" "recurrence":"FREQ=WEEKLY;BYDAY=TU,WE" } ``` would define a maintenance window between 01 and 07 hours UTC during each Tuesday and Wednesday. workloadsConfig: Optional. The workloads configuration settings for the Cloud Composer environment. It will be applied to the migrated environment. The workloads include Airflow scheduler, web server, triggerer, dag processor and workers. c$\rSrSrSrSrSrSrSrg)BMigrateEnvironmentRequest.GkeClusterRetentionPolicyValueValuesEnumiaRequired. The retention policy for the GKE cluster associated with the Cloud Composer 2 environment. The cluster can be retained or deleted after the migration. Values: GKE_CLUSTER_RETENTION_POLICY_UNSPECIFIED: Default value. DELETE_GKE_CLUSTER: GKE cluster will be deleted after environment migration. RETAIN_GKE_CLUSTER: GKE cluster will be retained after environment migration. rrrr N) r rrrr(GKE_CLUSTER_RETENTION_POLICY_UNSPECIFIEDDELETE_GKE_CLUSTERRETAIN_GKE_CLUSTERrr rr(GkeClusterRetentionPolicyValueValuesEnumr)s 01,rr-rrrrUrrVr N)r rrrrr#r$r-r)gkeClusterRetentionPolicyr.r7rQrrrr rrrrse< (112\^_`&&q),,,-@!D**+ FAILED: The operation is no longer running but did not succeed. rrrrUrVrWr N) r rrrrr'r rMr SUCCESSFULrrr rrrre@ s( GGIJ FrrrrrUrVrWrXr N)r rrrrr#r$rcrr.rr"r) operationTyperesource resourceUuidrrr rrrXrX s&Y^^2Y^^$$$Q'*  ! !! $'%%&DaH-  " "1 %(&&q),   4a 8%rrXc\rSrSrSrSrg)riZ zRequest to pause a DAG.r Nr r rrrrZ s rrc\rSrSrSr\R "S5r\R"S\RRS9r \R "S5r \R "S5r Srg ) ri^ a%Poll Airflow Command request. Fields: executionId: The unique ID of the command execution. nextLineNumber: Line number from which new logs should be fetched. pod: The name of the pod where the command is executed. podNamespace: The namespace of the pod where the command is executed. rrr!rUrVr N)r rrrrr#r.rr%r&r'nextLineNumberrrrr rrrr^ sW%%a(+))!Y5F5F5L5LM.a #&&q),rrc\rSrSrSr\R "SS5r\R "SSSS9r\R"S 5r S r g ) PollAirflowCommandResponsein a@Response to PollAirflowCommandRequest. Fields: exitInfo: The result exit status of the command. output: Output from the command execution. It may not contain the full output and the caller may need to poll for more lines. outputEnd: Whether the command execution has finished and there is no more output. rrrrTrMrUr N) r rrrrr#rQexitInfooutputrg outputEndrr rrrnrnn s? # #J 2(  ! !&!d ;&$$Q')rrnc\rSrSrSr\R "S5r\R"S5r \R"S5r Sr g)PrivateClusterConfigi~ aConfiguration options for the private GKE cluster in a Cloud Composer environment. Fields: enablePrivateEndpoint: Optional. If `true`, access to the public endpoint of the GKE cluster is denied. masterIpv4CidrBlock: Optional. The CIDR block from which IPv4 range for GKE master will be reserved. If left blank, the default value of '172.16.0.0/23' is used. masterIpv4ReservedRange: Output only. The IP range in CIDR notation to use for the hosted master network. This range is used for assigning internal IP addresses to the GKE cluster master or set of masters and to the internal load balancer virtual IP. This range must not overlap with any other ranges in use within the cluster's network. rrrUr N) r rrrrr#rgenablePrivateEndpointr.masterIpv4CidrBlockmasterIpv4ReservedRangerr rrrsrs~ s< $003!--a0%11!4rrsc\rSrSrSr\R "S5r\R "S5r\R "S5r \R "S5r \R"S5r \R"S5r \R"S 5r\R"S S 5r\R"S S 5r\R "S5r\R "S5rSrg)ri a The configuration information for configuring a Private IP Cloud Composer environment. Fields: cloudComposerConnectionSubnetwork: Optional. When specified, the environment will use Private Service Connect instead of VPC peerings to connect to Cloud SQL in the Tenant Project, and the PSC endpoint in the Customer Project will use an IP address from this subnetwork. cloudComposerNetworkIpv4CidrBlock: Optional. The CIDR block from which IP range for Cloud Composer Network in tenant project will be reserved. Needs to be disjoint from private_cluster_config.master_ipv4_cidr_block and cloud_sql_ipv4_cidr_block. This field is supported for Cloud Composer environments in versions composer-2.*.*-airflow-*.*.* and newer. cloudComposerNetworkIpv4ReservedRange: Output only. The IP range reserved for the tenant project's Cloud Composer network. This field is supported for Cloud Composer environments in versions composer-2.*.*-airflow-*.*.* and newer. cloudSqlIpv4CidrBlock: Optional. The CIDR block from which IP range in tenant project will be reserved for Cloud SQL. Needs to be disjoint from `web_server_ipv4_cidr_block`. enablePrivateBuildsOnly: Optional. If `true`, builds performed during operations that install Python packages have only private connectivity to Google services (including Artifact Registry) and VPC network (if either `NodeConfig.network` and `NodeConfig.subnetwork` fields or `NodeConfig.composer_network_attachment` field are specified). If `false`, the builds also have access to the internet. This field is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. enablePrivateEnvironment: Optional. If `true`, a Private IP Cloud Composer environment is created. If this field is set to true, `IPAllocationPolicy.use_ip_aliases` must be set to true for Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*. enablePrivatelyUsedPublicIps: Optional. When enabled, IPs from public (non-RFC1918) ranges can be used for `IPAllocationPolicy.cluster_ipv4_cidr_block` and `IPAllocationPolicy.service_ipv4_cidr_block`. networkingConfig: Optional. Configuration for the network connections configuration in the environment. privateClusterConfig: Optional. Configuration for the private GKE cluster for a Private IP Cloud Composer environment. webServerIpv4CidrBlock: Optional. The CIDR block from which IP range for web server will be reserved. Needs to be disjoint from `private_cluster_config.master_ipv4_cidr_block` and `cloud_sql_ipv4_cidr_block`. This field is supported for Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*. webServerIpv4ReservedRange: Output only. The IP range reserved for the tenant project's App Engine VMs. This field is supported for Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*. rrrUrVrWrXrr0rrsr*r+r,r N)r rrrrr#r.!cloudComposerConnectionSubnetwork!cloudComposerNetworkIpv4CidrBlock%cloudComposerNetworkIpv4ReservedRangecloudSqlIpv4CidrBlockrgenablePrivateBuildsOnlyenablePrivateEnvironmentenablePrivatelyUsedPublicIpsrQnetworkingConfigprivateClusterConfigwebServerIpv4CidrBlockwebServerIpv4ReservedRangerr rrrr s1f'0&;&;A&>#&/&;&;A&>#*3*?*?*B'#//2%2215&33A6!*!7!7!:++,>B"//0FJ$004(44R8rrc>\rSrSrSr\R "SS5rSrg)ri zThe Recovery settings of an environment. Fields: scheduledSnapshotsConfig: Optional. The configuration for scheduled snapshot creation mechanism. ScheduledSnapshotsConfigrr N) r rrrrr#rQscheduledSnapshotsConfigrr rrrr s'334NPQRrrc\rSrSrSrSrg)ri zRestart Airflow web server.r Nr r rrrr s$rrc<\rSrSrSr\R "S5rSrg)ri zRequest to create a snapshot of a Cloud Composer environment. Fields: snapshotLocation: Location in a Cloud Storage where the snapshot is going to be stored, e.g.: "gs://my-bucket/snapshots". rr N) r rrrrr#r.snapshotLocationrr rrrr s**1-rrc<\rSrSrSr\R "S5rSrg)SaveSnapshotResponsei aResponse to SaveSnapshotRequest. Fields: snapshotPath: The fully-resolved Cloud Storage path of the created snapshot, e.g.: "gs://my- bucket/snapshots/project_location_environment_timestamp". This field is populated only if the snapshot creation was successful. rr N) r rrrrr#r.rrr rrrr s&&q),rrc\rSrSrSr\R "S5r\R"S5r \R"S5r \R"S5r Sr g) ri a'The configuration for scheduled snapshot creation mechanism. Fields: enabled: Optional. Whether scheduled snapshots creation is enabled. snapshotCreationSchedule: Optional. The cron expression representing the time when snapshots creation mechanism runs. This field is subject to additional validation around frequency of execution. snapshotLocation: Optional. The Cloud Storage location for storing automatically created snapshots. timeZone: Optional. Time zone that sets the context to interpret snapshot_creation_schedule. rrrUrVr N) r rrrrr#rgrhr.snapshotCreationSchedulertimeZonerr rrrr sK   " "1 %'&2215**1-  " "1 %(rrc@\rSrSrSr\R "S\RRS9r \R"S\RRS9r \R"S\RRS9r \R"S\RRS9rSrg ) SchedulerResourcei aConfiguration for resources used by Airflow schedulers. Fields: count: Optional. The number of schedulers. cpu: Optional. CPU request and limit for a single Airflow scheduler replica. memoryGb: Optional. Memory (GB) request and limit for a single Airflow scheduler replica. storageGb: Optional. Storage (GB) request and limit for a single Airflow scheduler replica. rr!rrUrVr NrBr rrrr s   I,=,=,C,C D%Q (9(9(?(?@#  ! !!Y->->-D-D E(""1i.?.?.E.EF)rrc.\rSrSrSr"SS\R 5r"SS\R 5r"SS\R 5r \ R"S 5"S S \R55r \ R"S 5"S S \R55r\ R"S 5"SS\R55r\R "S S5r\R$"SS5r\R$"SS5r\R "SS5r\R "S S5r\R."S5r\R "SS5r\R."S5r\R6"S\R8R:S9r\R$"SS5rSr g)ri# aSpecifies the selection and configuration of software inside the environment. Enums: AirflowExecutorTypeValueValuesEnum: The `airflowExecutorType` specifies the [executor](https://airflow.apache.org/code.html?highlight=executor#e xecutors) by which task instances are run on Airflow. If this field is unspecified, the `airflowExecutorType` defaults to `celery`. AuditLogsReplicationModeValueValuesEnum: Optional. The selected mode of audit logs replication. This field is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. WebServerPluginsModeValueValuesEnum: Optional. Whether or not the web server uses custom plugins. If unspecified, the field defaults to `PLUGINS_ENABLED`. This field is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Messages: AirflowConfigOverridesValue: Optional. Apache Airflow configuration properties to override. Property keys contain the section and property names, separated by a hyphen, for example "core- dags_are_paused_at_creation". Section names must not contain hyphens ("-"), opening square brackets ("["), or closing square brackets ("]"). The property name must not be empty and must not contain an equals sign ("=") or semicolon (";"). Section and property names must not contain a period ("."). Apache Airflow configuration property names must be written in [snake_case](https://en.wikipedia.org/wiki/Snake_case). Property values can contain any character, and can be written in any lower/upper case format. Certain Apache Airflow configuration property values are [blocked](/composer/docs/concepts/airflow-configurations), and cannot be overridden. EnvVariablesValue: Optional. Additional environment variables to provide to the Apache Airflow scheduler, worker, and webserver processes. Environment variable names must match the regular expression `a-zA-Z_*`. They cannot specify Apache Airflow software configuration overrides (they cannot match the regular expression `AIRFLOW__[A-Z0-9_]+__[A-Z0-9_]+`), and they cannot match any of the following reserved names: * `AIRFLOW_HOME` * `C_FORCE_ROOT` * `CONTAINER_NAME` * `DAGS_FOLDER` * `GCP_PROJECT` * `GCS_BUCKET` * `GKE_CLUSTER_NAME` * `SQL_DATABASE` * `SQL_INSTANCE` * `SQL_PASSWORD` * `SQL_PROJECT` * `SQL_REGION` * `SQL_USER` PypiPackagesValue: Optional. Custom Python Package Index (PyPI) packages to be installed in the environment. Keys refer to the lowercase package name such as "numpy" and values are the lowercase extras and version specifier such as "==1.12.0", "[devel,gcp_api]", or "[devel]>=1.8.2, <1.9.2". To specify a package without pinning it to a version specifier, use the empty string as the value. Fields: airflowConfigOverrides: Optional. Apache Airflow configuration properties to override. Property keys contain the section and property names, separated by a hyphen, for example "core-dags_are_paused_at_creation". Section names must not contain hyphens ("-"), opening square brackets ("["), or closing square brackets ("]"). The property name must not be empty and must not contain an equals sign ("=") or semicolon (";"). Section and property names must not contain a period ("."). Apache Airflow configuration property names must be written in [snake_case](https://en.wikipedia.org/wiki/Snake_case). Property values can contain any character, and can be written in any lower/upper case format. Certain Apache Airflow configuration property values are [blocked](/composer/docs/concepts/airflow-configurations), and cannot be overridden. airflowExecutorType: The `airflowExecutorType` specifies the [executor](ht tps://airflow.apache.org/code.html?highlight=executor#executors) by which task instances are run on Airflow. If this field is unspecified, the `airflowExecutorType` defaults to `celery`. auditLogsReplicationMode: Optional. The selected mode of audit logs replication. This field is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. cloudDataLineageIntegration: Optional. The configuration for Cloud Data Lineage integration. envVariables: Optional. Additional environment variables to provide to the Apache Airflow scheduler, worker, and webserver processes. Environment variable names must match the regular expression `a-zA-Z_*`. They cannot specify Apache Airflow software configuration overrides (they cannot match the regular expression `AIRFLOW__[A-Z0-9_]+__[A-Z0-9_]+`), and they cannot match any of the following reserved names: * `AIRFLOW_HOME` * `C_FORCE_ROOT` * `CONTAINER_NAME` * `DAGS_FOLDER` * `GCP_PROJECT` * `GCS_BUCKET` * `GKE_CLUSTER_NAME` * `SQL_DATABASE` * `SQL_INSTANCE` * `SQL_PASSWORD` * `SQL_PROJECT` * `SQL_REGION` * `SQL_USER` imageVersion: Optional. The version of the software running in the environment. This encapsulates both the version of Cloud Composer functionality and the version of Apache Airflow. It must match the regular expression `composer-([0-9]+(\.[0-9]+\.[0-9]+(-preview\.[0- 9]+)?)?|latest)-airflow-([0-9]+(\.[0-9]+(\.[0-9]+)?)?)`. When used as input, the server also checks if the provided version is supported and denies the request for an unsupported version. The Cloud Composer portion of the image version is a full [semantic version](https://semver.org), or an alias in the form of major version number or `latest`. When an alias is provided, the server replaces it with the current Cloud Composer version that satisfies the alias. The Apache Airflow portion of the image version is a full semantic version that points to one of the supported Apache Airflow versions, or an alias in the form of only major or major.minor versions specified. When an alias is provided, the server replaces it with the latest Apache Airflow version that satisfies the alias and is supported in the given Cloud Composer version. In all cases, the resolved image version is stored in the same field. See also [version list](/composer/docs/concepts/versioning/composer-versions) and [versioning overview](/composer/docs/concepts/versioning/composer- versioning-overview). pypiPackages: Optional. Custom Python Package Index (PyPI) packages to be installed in the environment. Keys refer to the lowercase package name such as "numpy" and values are the lowercase extras and version specifier such as "==1.12.0", "[devel,gcp_api]", or "[devel]>=1.8.2, <1.9.2". To specify a package without pinning it to a version specifier, use the empty string as the value. pythonVersion: Optional. The major version of Python used to run the Apache Airflow scheduler, worker, and webserver processes. Can be set to '2' or '3'. If not specified, the default is '3'. Cannot be updated. This field is only supported for Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*. Environments in newer versions always use Python major version 3. schedulerCount: Optional. The number of schedulers for Airflow. This field is supported for Cloud Composer environments in versions composer-1.*.*-airflow-2.*.*. webServerPluginsMode: Optional. Whether or not the web server uses custom plugins. If unspecified, the field defaults to `PLUGINS_ENABLED`. This field is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. c$\rSrSrSrSrSrSrSrg)1SoftwareConfig.AirflowExecutorTypeValueValuesEnumi aThe `airflowExecutorType` specifies the [executor](https://airflow.apa che.org/code.html?highlight=executor#executors) by which task instances are run on Airflow. If this field is unspecified, the `airflowExecutorType` defaults to `celery`. Values: AIRFLOW_EXECUTOR_TYPE_UNSPECIFIED: The Airflow executor type is unspecified. CELERY: The Celery executor will be used. KUBERNETES: The Kubernetes executor will be used. rrrr N) r rrrr!AIRFLOW_EXECUTOR_TYPE_UNSPECIFIEDCELERY KUBERNETESrr rr"AirflowExecutorTypeValueValuesEnumr s )*% FJrrc$\rSrSrSrSrSrSrSrg)6SoftwareConfig.AuditLogsReplicationModeValueValuesEnumi aOptional. The selected mode of audit logs replication. This field is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Values: AUDIT_LOGS_REPLICATION_MODE_UNSPECIFIED: The user's choice of logs replication mode is unspecified. AUDIT_LOGS_REPLICATION_DISABLED: The user opted out of audit logs replication. AUDIT_LOGS_REPLICATION_ENABLED: The user opted in to audit logs replication. rrrr N) r rrrr'AUDIT_LOGS_REPLICATION_MODE_UNSPECIFIEDAUDIT_LOGS_REPLICATION_DISABLEDAUDIT_LOGS_REPLICATION_ENABLEDrr rr'AuditLogsReplicationModeValueValuesEnumr s /0+&'#%&"rrc$\rSrSrSrSrSrSrSrg)2SoftwareConfig.WebServerPluginsModeValueValuesEnumi aOptional. Whether or not the web server uses custom plugins. If unspecified, the field defaults to `PLUGINS_ENABLED`. This field is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Values: WEB_SERVER_PLUGINS_MODE_UNSPECIFIED: Default mode. PLUGINS_DISABLED: Web server plugins are not supported. PLUGINS_ENABLED: Web server plugins are supported. rrrr N) r rrrr#WEB_SERVER_PLUGINS_MODE_UNSPECIFIEDPLUGINS_DISABLEDPLUGINS_ENABLEDrr rr#WebServerPluginsModeValueValuesEnumr s +,'OrrrBcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) *SoftwareConfig.AirflowConfigOverridesValuei aOptional. Apache Airflow configuration properties to override. Property keys contain the section and property names, separated by a hyphen, for example "core-dags_are_paused_at_creation". Section names must not contain hyphens ("-"), opening square brackets ("["), or closing square brackets ("]"). The property name must not be empty and must not contain an equals sign ("=") or semicolon (";"). Section and property names must not contain a period ("."). Apache Airflow configuration property names must be written in [snake_case](https://en.wikipedia.org/wiki/Snake_case). Property values can contain any character, and can be written in any lower/upper case format. Certain Apache Airflow configuration property values are [blocked](/composer/docs/concepts/airflow-configurations), and cannot be overridden. Messages: AdditionalProperty: An additional property for a AirflowConfigOverridesValue object. Fields: additionalProperties: Additional properties of type AirflowConfigOverridesValue c`\rSrSrSr\R "S5r\R "S5rSr g)=SoftwareConfig.AirflowConfigOverridesValue.AdditionalPropertyi zAn additional property for a AirflowConfigOverridesValue object. Fields: key: Name of the additional property. value: A string attribute. rrr NrIr rrrKr rLrrKrTrMr NrOr rrAirflowConfigOverridesValuer s2. 'Y.. '%112FTXYrrcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) SoftwareConfig.EnvVariablesValuei aOptional. Additional environment variables to provide to the Apache Airflow scheduler, worker, and webserver processes. Environment variable names must match the regular expression `a-zA-Z_*`. They cannot specify Apache Airflow software configuration overrides (they cannot match the regular expression `AIRFLOW__[A-Z0-9_]+__[A-Z0-9_]+`), and they cannot match any of the following reserved names: * `AIRFLOW_HOME` * `C_FORCE_ROOT` * `CONTAINER_NAME` * `DAGS_FOLDER` * `GCP_PROJECT` * `GCS_BUCKET` * `GKE_CLUSTER_NAME` * `SQL_DATABASE` * `SQL_INSTANCE` * `SQL_PASSWORD` * `SQL_PROJECT` * `SQL_REGION` * `SQL_USER` Messages: AdditionalProperty: An additional property for a EnvVariablesValue object. Fields: additionalProperties: Additional properties of type EnvVariablesValue c`\rSrSrSr\R "S5r\R "S5rSr g)3SoftwareConfig.EnvVariablesValue.AdditionalPropertyi zAn additional property for a EnvVariablesValue object. Fields: key: Name of the additional property. value: A string attribute. rrr NrIr rrrKr rLrrKrTrMr NrOr rrEnvVariablesValuer s2$ 'Y.. '%112FTXYrrcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) SoftwareConfig.PypiPackagesValuei a!Optional. Custom Python Package Index (PyPI) packages to be installed in the environment. Keys refer to the lowercase package name such as "numpy" and values are the lowercase extras and version specifier such as "==1.12.0", "[devel,gcp_api]", or "[devel]>=1.8.2, <1.9.2". To specify a package without pinning it to a version specifier, use the empty string as the value. Messages: AdditionalProperty: An additional property for a PypiPackagesValue object. Fields: additionalProperties: Additional properties of type PypiPackagesValue c`\rSrSrSr\R "S5r\R "S5rSr g)3SoftwareConfig.PypiPackagesValue.AdditionalPropertyi% zAn additional property for a PypiPackagesValue object. Fields: key: Name of the additional property. value: A string attribute. rrr NrIr rrrKr% rLrrKrTrMr NrOr rrPypiPackagesValuer 2  'Y.. '%112FTXYrrrrrUrerVrWrXrrr*r!r+r N)!r rrrrr#r$rrrrrYrPrrrrQairflowConfigOverridesr)airflowExecutorTypeauditLogsReplicationModecloudDataLineageIntegration envVariablesr.r7 pypiPackages pythonVersionr%r&r'schedulerCountwebServerPluginsModerr rrrr# swr9>> ' '" INN  !!"89#ZI$5$5#Z:#ZJ !!"89Z)++Z:Z@ !!"89Z)++Z:Z:%112OQRS!++,PRST&001Z\]^ ) 6 67TVW X''(;Q?,&&q),''(;Q?,''*-))!Y5F5F5L5LM.",,-RTVWrrc<\rSrSrSr\R "S5rSrg) SourceCodei> zRA source code of a DAG. Fields: code: The source code of the user-defined DAG. rr N) r rrrrr#r.coderr rrrr> s   q !$rrc\rSrSrSr"SS\R 5r"SS\R 5r\R"SS5r \R"S5r \R"SS S S 9r \R"S 5r\R"S 5r\R"S5r\R"S5r\R$"SSS 9r\R"S5r\R"S5r\R"S5r\R"S5rSrg)StandardQueryParametersiH aQuery parameters accepted by all methods. Enums: FXgafvValueValuesEnum: V1 error format. AltValueValuesEnum: Data format for response. Fields: f__xgafv: V1 error format. access_token: OAuth access token. alt: Data format for response. callback: JSONP fields: Selector specifying which fields to include in a partial response. key: API key. Your API key identifies your project and provides you with API access, quota, and reports. Required unless you provide an OAuth 2.0 token. oauth_token: OAuth 2.0 token for the current user. prettyPrint: Returns response with indentations and line breaks. quotaUser: Available to use for quota purposes for server-side applications. Can be any arbitrary string assigned to a user, but should not exceed 40 characters. trace: A tracing token of the form "token:" to include in api requests. uploadType: Legacy upload protocol for media (e.g. "media", "multipart"). upload_protocol: Upload protocol for media (e.g. "raw", "multipart"). c$\rSrSrSrSrSrSrSrg)*StandardQueryParameters.AltValueValuesEnumic zData format for response. Values: json: Responses with Content-Type of application/json media: Media download with context-dependent Content-Type proto: Responses with Content-Type of application/x-protobuf rrrr N) r rrrrjsonmediaprotorr rrAltValueValuesEnumrc s D E Errc \rSrSrSrSrSrSrg)-StandardQueryParameters.FXgafvValueValuesEnumio zFV1 error format. Values: _1: v1 error format _2: v2 error format rrr N)r rrrr_1_2rr rrFXgafvValueValuesEnumro s B BrrrrrUr)defaultrVrWrXrrTr*r+r,r-r N)r rrrrr#r$rrr)f__xgafvr. access_tokenaltcallbackfieldsrJ oauth_tokenrg prettyPrint quotaUsertrace uploadTypeupload_protocolrr rrrrH s4 9>>  inn  !8! <(&&q),0!VD#  " "1 %(   #&a #%%a(+&&q$7+##A&)    #%$$R(*))"-/rrc\rSrSrSr\R "S5"SS\R55r \R"S\RRS9r \R"SSS S 9r\R "S 5rS rg )rSi aThe `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by [gRPC](https://github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the [API Design Guide](https://cloud.google.com/apis/design/errors). Messages: DetailsValueListEntry: A DetailsValueListEntry object. Fields: code: The status code, which should be an enum value of google.rpc.Code. details: A list of messages that carry the error details. There is a common set of message types for APIs to use. message: A developer-facing error message, which should be in English. Any user-facing error message should be localized and sent in the google.rpc.Status.details field, or localized by the client. rBcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Status.DetailsValueListEntryi zA DetailsValueListEntry object. Messages: AdditionalProperty: An additional property for a DetailsValueListEntry object. Fields: additionalProperties: Properties of the object. Contains field @type with type URL. cb\rSrSrSr\R "S5r\R"SS5r Sr g)/Status.DetailsValueListEntry.AdditionalPropertyi zAn additional property for a DetailsValueListEntry object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. rrJrr NrKr rrrKr rLrrKrTrMr NrOr rrDetailsValueListEntryr s4  AY.. A%112FTXYrrrr!rTrMrUr N)r rrrrrrYr#rPrr%r&r'rrQdetailsr.rrr rrrSrS s|& !!"89Zi//Z:Z2   9+<+<+B+B C$  " "#:A M'  ! !! $'rrSc\rSrSrSr\R "S5r\R"S5r \R "S5r \R "S5r Sr g) ri asStop Airflow Command request. Fields: executionId: The unique ID of the command execution. force: If true, the execution is terminated forcefully (SIGKILL). If false, the execution is stopped gracefully, giving it time for cleanup. pod: The name of the pod where the command is executed. podNamespace: The namespace of the pod where the command is executed. rrrUrVr N) r rrrrr#r.rrgforcerrrr rrrr sI%%a(+   #%a #&&q),rrc^\rSrSrSr\R "S5r\R"SSS9r Sr g) StopAirflowCommandResponsei zResponse to StopAirflowCommandRequest. Fields: isDone: Whether the execution is still running. output: Output message from stopping execution request. rrTrMr N) r rrrrr#rgisDoner.rprr rrrr s+  ! !! $&  T 2&rrcb\rSrSrSr\R "S5r\R"SS5r Sr g)ri aThe configuration for data storage in the environment. Fields: bucket: Optional. The name of the Cloud Storage bucket used by the environment. No `gs://` prefix. filestoreConfig: Optional. The configuration for data storage in the environment using Filestore. rrrr N) r rrrrr#r.bucketrQfilestoreConfigrr rrrr s,   #&**+> ((I4E4E4K4KL-##$@!D+rrjc\rSrSrSr\R "S5"SS\R55r \R"SS5r \R"S5r \R"S5rS rg ) ri aWRequest to trigger a DAG run. Messages: ConfValue: The key-value pairs get pickled into the conf attribute in the DAG run. Fields: conf: The key-value pairs get pickled into the conf attribute in the DAG run. dagRunId: The dag_run_id to be assigned to the triggered DAG run. executionDate: The execution date of the DAG run. rBcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) TriggerDagRequest.ConfValuei zThe key-value pairs get pickled into the conf attribute in the DAG run. Messages: AdditionalProperty: An additional property for a ConfValue object. Fields: additionalProperties: Properties of the object. cb\rSrSrSr\R "S5r\R"SS5r Sr g).TriggerDagRequest.ConfValue.AdditionalPropertyi zAn additional property for a ConfValue object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. rrJrr NrKr rrrKr* rLrrKrTrMr NrOr rr ConfValuer( s4 AY.. A%112FTXYrr+rrrUr N)r rrrrrrYr#rPr+rQconfr.rVrYrr rrrr sk  !!"89Z)##Z:Z0    Q /$  " "1 %(''*-rrc\rSrSrSr\R "S\RRS9r \R"S\RRS9r \R"S\RRS9r Srg) TriggererResourcei a!Configuration for resources used by Airflow triggerers. Fields: count: Optional. The number of triggerers. cpu: Optional. CPU request and limit for a single Airflow triggerer replica. memoryGb: Optional. Memory (GB) request and limit for a single Airflow triggerer replica. rr!rrUr N)r rrrrr#r%r&r'rCrDrErFrGrr rrr.r. sc  I,=,=,C,C D%Q (9(9(?(?@#  ! !!Y->->-D-D E(rr.c\rSrSrSr\R "S5"SS\R55r \R"SS5r \R"S5r Srg ) ri aQUser workloads ConfigMap used by Airflow tasks that run with Kubernetes executor or KubernetesPodOperator. Messages: DataValue: Optional. The "data" field of Kubernetes ConfigMap, organized in key-value pairs. For details see: https://kubernetes.io/docs/concepts/configuration/configmap/ Example: { "example_key": "example_value", "another_key": "another_value" } Fields: data: Optional. The "data" field of Kubernetes ConfigMap, organized in key-value pairs. For details see: https://kubernetes.io/docs/concepts/configuration/configmap/ Example: { "example_key": "example_value", "another_key": "another_value" } name: Identifier. The resource name of the ConfigMap, in the form: "projec ts/{projectId}/locations/{locationId}/environments/{environmentId}/userW orkloadsConfigMaps/{userWorkloadsConfigMapId}" rBcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) UserWorkloadsConfigMap.DataValuei aOptional. The "data" field of Kubernetes ConfigMap, organized in key- value pairs. For details see: https://kubernetes.io/docs/concepts/configuration/configmap/ Example: { "example_key": "example_value", "another_key": "another_value" } Messages: AdditionalProperty: An additional property for a DataValue object. Fields: additionalProperties: Additional properties of type DataValue c`\rSrSrSr\R "S5r\R "S5rSr g)3UserWorkloadsConfigMap.DataValue.AdditionalPropertyi }An additional property for a DataValue object. Fields: key: Name of the additional property. value: A string attribute. rrr NrIr rrrKr3 rLrrKrTrMr NrOr rr DataValuer1 rSrr5rrr Nr rrrrrrYr#rPr5rQdatar.ryrr rrrr s[& !!"89Z)##Z:Z4    Q /$   q !$rrc\rSrSrSr\R "S5"SS\R55r \R"SS5r \R"S5r Srg ) ri+ aUser workloads Secret used by Airflow tasks that run with Kubernetes executor or KubernetesPodOperator. Messages: DataValue: Optional. The "data" field of Kubernetes Secret, organized in key-value pairs, which can contain sensitive values such as a password, a token, or a key. The values for all keys have to be base64-encoded strings. For details see: https://kubernetes.io/docs/concepts/configuration/secret/ Example: { "example": "ZXhhbXBsZV92YWx1ZQ==", "another-example": "YW5vdGhlcl9leGFtcGxlX3ZhbHVl" } Fields: data: Optional. The "data" field of Kubernetes Secret, organized in key- value pairs, which can contain sensitive values such as a password, a token, or a key. The values for all keys have to be base64-encoded strings. For details see: https://kubernetes.io/docs/concepts/configuration/secret/ Example: { "example": "ZXhhbXBsZV92YWx1ZQ==", "another-example": "YW5vdGhlcl9leGFtcGxlX3ZhbHVl" } name: Identifier. The resource name of the Secret, in the form: "projects/ {projectId}/locations/{locationId}/environments/{environmentId}/userWork loadsSecrets/{userWorkloadsSecretId}" rBcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) UserWorkloadsSecret.DataValueiE aOptional. The "data" field of Kubernetes Secret, organized in key- value pairs, which can contain sensitive values such as a password, a token, or a key. The values for all keys have to be base64-encoded strings. For details see: https://kubernetes.io/docs/concepts/configuration/secret/ Example: { "example": "ZXhhbXBsZV92YWx1ZQ==", "another-example": "YW5vdGhlcl9leGFtcGxlX3ZhbHVl" } Messages: AdditionalProperty: An additional property for a DataValue object. Fields: additionalProperties: Additional properties of type DataValue c`\rSrSrSr\R "S5r\R "S5rSr g)0UserWorkloadsSecret.DataValue.AdditionalPropertyiV r4rrr NrIr rrrKr<V rLrrKrTrMr NrOr rrr5r:E rrr5rrr Nr6r rrrr+ s[2 !!"89Z)##Z:Z:    Q /$   q !$rrc<\rSrSrSr\R "S5rSrg)rig a The configuration settings for the Airflow web server App Engine instance. Supported for Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*. Fields: machineType: Optional. Machine type on which Airflow web server is running. It has to be one of: composer-n1-webserver-2, composer-n1-webserver-4 or composer-n1-webserver-8. If not specified, composer-n1-webserver-2 will be used. Value custom is returned only in response, if Airflow web server parameters were manually changed to a non-standard values. rr N) r rrrrr#r.rrrr rrrrg s %%a(+rrc<\rSrSrSr\R "SSSS9rSrg) rix zNetwork-level access control policy for the Airflow web server. Fields: allowedIpRanges: A collection of allowed IP ranges with descriptions. r,rTrMr N) r rrrrr#rQallowedIpRangesrr rrrrx s **+;QN/rrc@\rSrSrSr\R "S\RRS9r \R"S\RRS9r \R"S\RRS9r \R"S\RRS9rSrg ) WebServerResourcei aConfiguration for resources used by Airflow web server. Fields: count: Optional. The number of web server instances. If not provided or set to 0, a single web server instance will be created. cpu: Optional. CPU request and limit for Airflow web server. memoryGb: Optional. Memory (GB) request and limit for Airflow web server. storageGb: Optional. Storage (GB) request and limit for Airflow web server. rr!rrUrVr NrBr rrrArA s   I,=,=,C,C D%Q (9(9(?(?@#  ! !!Y->->-D-D E(""1i.?.?.E.EF)rrAc\rSrSrSr\R "S\RRS9r \R"S\RRS9r \R "S\RRS9r \R"S\RRS9r\R "S\RRS9rS rg ) WorkerResourcei aConfiguration for resources used by Airflow workers. Fields: cpu: Optional. CPU request and limit for a single Airflow worker replica. maxCount: Optional. Maximum number of workers for autoscaling. memoryGb: Optional. Memory (GB) request and limit for a single Airflow worker replica. minCount: Optional. Minimum number of workers for autoscaling. storageGb: Optional. Storage (GB) request and limit for a single Airflow worker replica. rr!rrUrVrWr N)r rrrrr#rDr&rErFr%r'maxCountrGminCountrHrr rrrCrC s  Q (9(9(?(?@#  # #Ay/@/@/F/F G(  ! !!Y->->-D-D E(  # #Ay/@/@/F/F G(""1i.?.?.E.EF)rrCc\rSrSrSr\R "SS5r\R "SS5r\R"S\RRS9r \R "S S 5r \R "S S 5r\R "S S5r\R"S\RRS9r\R""S\RR$S9r\R""S\RR$S9rSrg)ri aThe Kubernetes workloads configuration for GKE cluster associated with the Cloud Composer environment. Supported for Cloud Composer environments in versions composer-2.*.*-airflow-*.*.* and newer. Fields: dagProcessor: Optional. Resources used by Airflow DAG processors. This field is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. scheduler: Optional. Resources used by Airflow scheduler. schedulerCpu: Optional. CPU request and limit for Airflow scheduler. triggerer: Optional. Resources used by Airflow triggerers. webServer: Optional. Resources used by Airflow web server. worker: Optional. Resources used by Airflow workers. workerCpu: Optional. CPU request and limit for Airflow worker. workerMaxCount: Optional. Maximum number of workers for autoscaling. workerMinCount: Optional. Minimum number of workers for autoscaling. rArrrrUr!r.rVrArWrCrXrrr*r N)r rrrrr#rQ dagProcessor schedulerrDr&rE schedulerCpu triggerer webServerworker workerCpur%r'workerMaxCountworkerMinCountrr rrrr s$''(>B,$$%8!<)%%a1B1B1H1HI,$$%8!<)$$%8!<)  ! !"2A 6&""1i.?.?.E.EF)))!Y5F5F5L5LM.))!Y5F5F5L5LM.rrrz$.xgafvr1r2rzinterval.endTimerzinterval.startTimeN)r __future__rapitools.base.protorpcliterr#apitools.base.pyrrpackagerPr rr,r2r5r9r`rerjrqrvr{rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrTrrArJr\r`rqrrvrxr}rrsrrrrrrrrrrrrrrrrrr r rrrrr rrrr0rrrXrrrnrsrrrrrrrrrrrSrrrrr rjrr.rrrrrArCrAddCustomJsonFieldMappingAddCustomJsonEnumMappingrr rrrXs  '<%( #**#I9+<+<I:#Y&&#$=Y..=*)++*:HH9,,HHV ) !! )&)"3"3& 8y?P?P 8 39J9J 3 1y?P?P 1 1ARAR 1O)BSBSO4 1iN_N_ 13yO`O`3* 1):K:K 1 0IDUDU 0 39;L;L 3 ' @Q@Q'. AIO>O E 89CTCT 819J9J1 [ HYHY [ 8)J[J[ 8 1i6G6G 1 '9CTCT ' 3y7H7H 3 Iy?P?P I 1):K:K 1o( 8I8Io(d UYEVEV U Q9CTCT Q Iy?P?P I UYEVEV UOPYPaPaO" 1PYPaPa 1 1YM^M^ 13iN_N_3& IYM^M^ I 1YM^M^ 1 1)J[J[ 139K\K\3$3 @Q@Q3.3 8I8I3& 1y7H7H 11y7H7H11I4E4E13Y5F5F30'7y(('7T#+Y..#+L7Y&&78H:)  H:VG9,,G,F8Y  F8R Ry  R (U)++(UV"Y&&"*i///y00/D9  D4I   (y(( (`#)##`#FBB ))BBJ(9#4#4(" *I$5$5 * Hy  H.i&7&7.& "i'' " ,+**,+^.9$$.0 ()## ( J9   J +)++ + +9,, + +y(( + +y00 + + 1 1 + +y00 +8Y..8$ K 1 1 K ; )) ; _)*;*; _ Yy'8'8 Y KI-- K*)++*.*9,,*' ))'2&Y%6%6&"2A 1 12Aj!Ky((!KHv2""v2ri8 !!i8XD9 ))D9N!i''! * 1 1 * (!2!2 ( 59,,5,>9y00>9BSY&&S%i//%.)++. *9,, *&y00&(G ))G&XXY&&XXv""""<.i//<.~0%Y  0%f* 1 1*" 3!2!2 3 AI%% AQ)9  Q)haJ9$$aJHEi//E>)+ )))+X F )) F 0"Y..0"f9")++9"x)i'')"OI$5$5OG ))G$GY&&G(Ni''N< ""Z4!!114>!!114>""=?QSeg""=?SUikr