Package Methods (1.18.0)
Summary of entries of Methods for composer.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient
EnvironmentsAsyncClient(*,credentials:typing.Optional[google.auth.credentials.Credentials]=None,transport:typing.Optional[typing.Union[str,google.cloud.orchestration.airflow.service_v1.services.environments.transports.base.EnvironmentsTransport,typing.Callable[[...],google.cloud.orchestration.airflow.service_v1.services.environments.transports.base.EnvironmentsTransport]]]='grpc_asyncio',client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,client_info:google.api_core.gapic_v1.client_info.ClientInfo=Instantiates the environments async client.
See more:google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.check_upgrade
check_upgrade(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.CheckUpgradeRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationCheck if an upgrade operation on the environment willsucceed.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_folder_path
common_folder_path(folder:str)->strReturns a fully-qualified folder string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_location_path
common_location_path(project:str,location:str)->strReturns a fully-qualified location string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_organization_path
common_organization_path(organization:str)->strReturns a fully-qualified organization string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_project_path
common_project_path(project:str)->strReturns a fully-qualified project string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.create_environment
create_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.CreateEnvironmentRequest,dict,]]=None,*,parent:typing.Optional[str]=None,environment:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.Environment]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationCreate a new environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.create_user_workloads_config_map
create_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.CreateUserWorkloadsConfigMapRequest,dict,]]=None,*,parent:typing.Optional[str]=None,user_workloads_config_map:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap)Creates a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.create_user_workloads_secret
create_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.CreateUserWorkloadsSecretRequest,dict,]]=None,*,parent:typing.Optional[str]=None,user_workloads_secret:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret)Creates a user workloads Secret.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.database_failover
database_failover(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.DatabaseFailoverRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationTriggers database failover (only for highly resilientenvironments).
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.delete_environment
delete_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.DeleteEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationDelete an environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.delete_operation
delete_operation(request:typing.Optional[google.longrunning.operations_pb2.DeleteOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a long-running operation.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.delete_user_workloads_config_map
delete_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.DeleteUserWorkloadsConfigMapRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.delete_user_workloads_secret
delete_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.DeleteUserWorkloadsSecretRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a user workloads Secret.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.environment_path
environment_path(project:str,location:str,environment:str)->strReturns a fully-qualified environment string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.execute_airflow_command
execute_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.ExecuteAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.ExecuteAirflowCommandResponse)Executes Airflow CLI command.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.fetch_database_properties
fetch_database_properties(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.FetchDatabasePropertiesRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.FetchDatabasePropertiesResponse)Fetches database properties.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_environment
get_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.GetEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.cloud.orchestration.airflow.service_v1.types.environments.EnvironmentGet an existing environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,)Return the API endpoint and client cert source for mutual TLS.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_transport_class
get_transport_class(label:typing.Optional[str]=None,)->typing.Type[google.cloud.orchestration.airflow.service_v1.services.environments.transports.base.EnvironmentsTransport]Returns an appropriate transport class.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_user_workloads_config_map
get_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.GetUserWorkloadsConfigMapRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap)Gets an existing user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_user_workloads_secret
get_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.GetUserWorkloadsSecretRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret)Gets an existing user workloads Secret.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.list_environments
list_environments(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListEnvironmentsAsyncPager)List environments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.list_operations
list_operations(request:typing.Optional[google.longrunning.operations_pb2.ListOperationsRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.list_user_workloads_config_maps
list_user_workloads_config_maps(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsConfigMapsAsyncPager)Lists user workloads ConfigMaps.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.list_user_workloads_secrets
list_user_workloads_secrets(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsSecretsAsyncPager)Lists user workloads Secrets.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.list_workloads
list_workloads(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListWorkloadsAsyncPager)Lists workloads in a Cloud Composer environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.load_snapshot
load_snapshot(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.LoadSnapshotRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationLoads a snapshot of a Cloud Composer environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_common_folder_path
parse_common_folder_path(path:str)->typing.Dict[str,str]Parse a folder path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_common_location_path
parse_common_location_path(path:str)->typing.Dict[str,str]Parse a location path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_common_organization_path
parse_common_organization_path(path:str)->typing.Dict[str,str]Parse a organization path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_common_project_path
parse_common_project_path(path:str)->typing.Dict[str,str]Parse a project path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_environment_path
parse_environment_path(path:str)->typing.Dict[str,str]Parses a environment path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_user_workloads_config_map_path
parse_user_workloads_config_map_path(path:str)->typing.Dict[str,str]Parses a user_workloads_config_map path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_user_workloads_secret_path
parse_user_workloads_secret_path(path:str)->typing.Dict[str,str]Parses a user_workloads_secret path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.poll_airflow_command
poll_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.PollAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.PollAirflowCommandResponse)Polls Airflow CLI command execution and fetches logs.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.save_snapshot
save_snapshot(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.SaveSnapshotRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationCreates a snapshots of a Cloud Composer environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.stop_airflow_command
stop_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.StopAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.StopAirflowCommandResponse)Stops Airflow CLI command execution.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.update_environment
update_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.UpdateEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,environment:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.Environment]=None,update_mask:typing.Optional[google.protobuf.field_mask_pb2.FieldMask]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationUpdate an environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.update_user_workloads_config_map
update_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.UpdateUserWorkloadsConfigMapRequest,dict,]]=None,*,user_workloads_config_map:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap)Updates a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.update_user_workloads_secret
update_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.UpdateUserWorkloadsSecretRequest,dict,]]=None,*,user_workloads_secret:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret)Updates a user workloads Secret.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.user_workloads_config_map_path
user_workloads_config_map_path(project:str,location:str,environment:str,user_workloads_config_map:str)->strReturns a fully-qualified user_workloads_config_map string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.user_workloads_secret_path
user_workloads_secret_path(project:str,location:str,environment:str,user_workloads_secret:str)->strReturns a fully-qualified user_workloads_secret string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient
EnvironmentsClient(*,credentials:typing.Optional[google.auth.credentials.Credentials]=None,transport:typing.Optional[typing.Union[str,google.cloud.orchestration.airflow.service_v1.services.environments.transports.base.EnvironmentsTransport,typing.Callable[[...],google.cloud.orchestration.airflow.service_v1.services.environments.transports.base.EnvironmentsTransport]]]=None,client_options:typing.Optional[typing.Union[google.api_core.client_options.ClientOptions,dict]]=None,client_info:google.api_core.gapic_v1.client_info.ClientInfo=Instantiates the environments client.
See more:google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.__exit__
__exit__(type,value,traceback)Releases underlying transport's resources.
See more:google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.exit
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.check_upgrade
check_upgrade(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.CheckUpgradeRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationCheck if an upgrade operation on the environment willsucceed.
See more:google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.check_upgrade
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_folder_path
common_folder_path(folder:str)->strReturns a fully-qualified folder string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_location_path
common_location_path(project:str,location:str)->strReturns a fully-qualified location string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_organization_path
common_organization_path(organization:str)->strReturns a fully-qualified organization string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_project_path
common_project_path(project:str)->strReturns a fully-qualified project string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.create_environment
create_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.CreateEnvironmentRequest,dict,]]=None,*,parent:typing.Optional[str]=None,environment:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.Environment]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationCreate a new environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.create_user_workloads_config_map
create_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.CreateUserWorkloadsConfigMapRequest,dict,]]=None,*,parent:typing.Optional[str]=None,user_workloads_config_map:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap)Creates a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.create_user_workloads_secret
create_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.CreateUserWorkloadsSecretRequest,dict,]]=None,*,parent:typing.Optional[str]=None,user_workloads_secret:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret)Creates a user workloads Secret.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.database_failover
database_failover(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.DatabaseFailoverRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationTriggers database failover (only for highly resilientenvironments).
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.delete_environment
delete_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.DeleteEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationDelete an environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.delete_operation
delete_operation(request:typing.Optional[google.longrunning.operations_pb2.DeleteOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a long-running operation.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.delete_user_workloads_config_map
delete_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.DeleteUserWorkloadsConfigMapRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.delete_user_workloads_secret
delete_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.DeleteUserWorkloadsSecretRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a user workloads Secret.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.environment_path
environment_path(project:str,location:str,environment:str)->strReturns a fully-qualified environment string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.execute_airflow_command
execute_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.ExecuteAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.ExecuteAirflowCommandResponse)Executes Airflow CLI command.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.fetch_database_properties
fetch_database_properties(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.FetchDatabasePropertiesRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.FetchDatabasePropertiesResponse)Fetches database properties.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.get_environment
get_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.GetEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.cloud.orchestration.airflow.service_v1.types.environments.EnvironmentGet an existing environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,)Deprecated.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more:google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.get_operation
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.get_user_workloads_config_map
get_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.GetUserWorkloadsConfigMapRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap)Gets an existing user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.get_user_workloads_secret
get_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.GetUserWorkloadsSecretRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret)Gets an existing user workloads Secret.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.list_environments
list_environments(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListEnvironmentsPager)List environments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.list_operations
list_operations(request:typing.Optional[google.longrunning.operations_pb2.ListOperationsRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.list_user_workloads_config_maps
list_user_workloads_config_maps(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsConfigMapsPager)Lists user workloads ConfigMaps.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.list_user_workloads_secrets
list_user_workloads_secrets(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsSecretsPager)Lists user workloads Secrets.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.list_workloads
list_workloads(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListWorkloadsPager)Lists workloads in a Cloud Composer environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.load_snapshot
load_snapshot(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.LoadSnapshotRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationLoads a snapshot of a Cloud Composer environment.
See more:google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.load_snapshot
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_common_folder_path
parse_common_folder_path(path:str)->typing.Dict[str,str]Parse a folder path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_common_location_path
parse_common_location_path(path:str)->typing.Dict[str,str]Parse a location path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_common_organization_path
parse_common_organization_path(path:str)->typing.Dict[str,str]Parse a organization path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_common_project_path
parse_common_project_path(path:str)->typing.Dict[str,str]Parse a project path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_environment_path
parse_environment_path(path:str)->typing.Dict[str,str]Parses a environment path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_user_workloads_config_map_path
parse_user_workloads_config_map_path(path:str)->typing.Dict[str,str]Parses a user_workloads_config_map path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_user_workloads_secret_path
parse_user_workloads_secret_path(path:str)->typing.Dict[str,str]Parses a user_workloads_secret path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.poll_airflow_command
poll_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.PollAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.PollAirflowCommandResponse)Polls Airflow CLI command execution and fetches logs.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.save_snapshot
save_snapshot(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.SaveSnapshotRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationCreates a snapshots of a Cloud Composer environment.
See more:google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.save_snapshot
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.stop_airflow_command
stop_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.StopAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.StopAirflowCommandResponse)Stops Airflow CLI command execution.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.update_environment
update_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.UpdateEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,environment:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.Environment]=None,update_mask:typing.Optional[google.protobuf.field_mask_pb2.FieldMask]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationUpdate an environment.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.update_user_workloads_config_map
update_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.UpdateUserWorkloadsConfigMapRequest,dict,]]=None,*,user_workloads_config_map:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap)Updates a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.update_user_workloads_secret
update_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.environments.UpdateUserWorkloadsSecretRequest,dict,]]=None,*,user_workloads_secret:typing.Optional[google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret)Updates a user workloads Secret.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.user_workloads_config_map_path
user_workloads_config_map_path(project:str,location:str,environment:str,user_workloads_config_map:str)->strReturns a fully-qualified user_workloads_config_map string.
google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.user_workloads_secret_path
user_workloads_secret_path(project:str,location:str,environment:str,user_workloads_secret:str)->strReturns a fully-qualified user_workloads_secret string.
google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListEnvironmentsAsyncPager
ListEnvironmentsAsyncPager(method:typing.Callable[[...],typing.Awaitable[google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsResponse],],request:google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsRequest,response:google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiates the pager.
google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListEnvironmentsPager
ListEnvironmentsPager(method:typing.Callable[[...],google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsResponse,],request:google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsRequest,response:google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiate the pager.
See more:google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListEnvironmentsPager
google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsConfigMapsAsyncPager
ListUserWorkloadsConfigMapsAsyncPager(method:typing.Callable[[...],typing.Awaitable[google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsResponse],],request:google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsRequest,response:google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiates the pager.
google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsConfigMapsPager
ListUserWorkloadsConfigMapsPager(method:typing.Callable[[...],google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsResponse,],request:google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsRequest,response:google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiate the pager.
google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsSecretsAsyncPager
ListUserWorkloadsSecretsAsyncPager(method:typing.Callable[[...],typing.Awaitable[google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsResponse],],request:google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsRequest,response:google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiates the pager.
google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsSecretsPager
ListUserWorkloadsSecretsPager(method:typing.Callable[[...],google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsResponse,],request:google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsRequest,response:google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiate the pager.
google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListWorkloadsAsyncPager
ListWorkloadsAsyncPager(method:typing.Callable[[...],typing.Awaitable[google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsResponse],],request:google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsRequest,response:google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiates the pager.
See more:google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListWorkloadsAsyncPager
google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListWorkloadsPager
ListWorkloadsPager(method:typing.Callable[[...],google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsResponse,],request:google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsRequest,response:google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiate the pager.
See more:google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListWorkloadsPager
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient
ImageVersionsAsyncClient(*,credentials:typing.Optional[google.auth.credentials.Credentials]=None,transport:typing.Optional[typing.Union[str,google.cloud.orchestration.airflow.service_v1.services.image_versions.transports.base.ImageVersionsTransport,typing.Callable[[...],google.cloud.orchestration.airflow.service_v1.services.image_versions.transports.base.ImageVersionsTransport]]]='grpc_asyncio',client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,client_info:google.api_core.gapic_v1.client_info.ClientInfo=Instantiates the image versions async client.
See more:google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_folder_path
common_folder_path(folder:str)->strReturns a fully-qualified folder string.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_location_path
common_location_path(project:str,location:str)->strReturns a fully-qualified location string.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_organization_path
common_organization_path(organization:str)->strReturns a fully-qualified organization string.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_project_path
common_project_path(project:str)->strReturns a fully-qualified project string.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.delete_operation
delete_operation(request:typing.Optional[google.longrunning.operations_pb2.DeleteOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a long-running operation.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,)Return the API endpoint and client cert source for mutual TLS.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.get_transport_class
get_transport_class(label:typing.Optional[str]=None,)->typing.Type[google.cloud.orchestration.airflow.service_v1.services.image_versions.transports.base.ImageVersionsTransport]Returns an appropriate transport class.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.list_image_versions
list_image_versions(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.services.image_versions.pagers.ListImageVersionsAsyncPager)List ImageVersions for provided location.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.list_operations
list_operations(request:typing.Optional[google.longrunning.operations_pb2.ListOperationsRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.parse_common_folder_path
parse_common_folder_path(path:str)->typing.Dict[str,str]Parse a folder path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.parse_common_location_path
parse_common_location_path(path:str)->typing.Dict[str,str]Parse a location path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.parse_common_organization_path
parse_common_organization_path(path:str)->typing.Dict[str,str]Parse a organization path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.parse_common_project_path
parse_common_project_path(path:str)->typing.Dict[str,str]Parse a project path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient
ImageVersionsClient(*,credentials:typing.Optional[google.auth.credentials.Credentials]=None,transport:typing.Optional[typing.Union[str,google.cloud.orchestration.airflow.service_v1.services.image_versions.transports.base.ImageVersionsTransport,typing.Callable[[...],google.cloud.orchestration.airflow.service_v1.services.image_versions.transports.base.ImageVersionsTransport]]]=None,client_options:typing.Optional[typing.Union[google.api_core.client_options.ClientOptions,dict]]=None,client_info:google.api_core.gapic_v1.client_info.ClientInfo=Instantiates the image versions client.
See more:google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.__exit__
__exit__(type,value,traceback)Releases underlying transport's resources.
See more:google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.exit
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_folder_path
common_folder_path(folder:str)->strReturns a fully-qualified folder string.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_location_path
common_location_path(project:str,location:str)->strReturns a fully-qualified location string.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_organization_path
common_organization_path(organization:str)->strReturns a fully-qualified organization string.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_project_path
common_project_path(project:str)->strReturns a fully-qualified project string.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.delete_operation
delete_operation(request:typing.Optional[google.longrunning.operations_pb2.DeleteOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a long-running operation.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,)Deprecated.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.list_image_versions
list_image_versions(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1.services.image_versions.pagers.ListImageVersionsPager)List ImageVersions for provided location.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.list_operations
list_operations(request:typing.Optional[google.longrunning.operations_pb2.ListOperationsRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.parse_common_folder_path
parse_common_folder_path(path:str)->typing.Dict[str,str]Parse a folder path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.parse_common_location_path
parse_common_location_path(path:str)->typing.Dict[str,str]Parse a location path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.parse_common_organization_path
parse_common_organization_path(path:str)->typing.Dict[str,str]Parse a organization path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.parse_common_project_path
parse_common_project_path(path:str)->typing.Dict[str,str]Parse a project path into its component segments.
google.cloud.orchestration.airflow.service_v1.services.image_versions.pagers.ListImageVersionsAsyncPager
ListImageVersionsAsyncPager(method:typing.Callable[[...],typing.Awaitable[google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsResponse],],request:google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsRequest,response:google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiates the pager.
google.cloud.orchestration.airflow.service_v1.services.image_versions.pagers.ListImageVersionsPager
ListImageVersionsPager(method:typing.Callable[[...],google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsResponse,],request:google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsRequest,response:google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiate the pager.
See more:google.cloud.orchestration.airflow.service_v1.services.image_versions.pagers.ListImageVersionsPager
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient
EnvironmentsAsyncClient(*,credentials:typing.Optional[google.auth.credentials.Credentials]=None,transport:typing.Optional[typing.Union[str,google.cloud.orchestration.airflow.service_v1beta1.services.environments.transports.base.EnvironmentsTransport,typing.Callable[[...],google.cloud.orchestration.airflow.service_v1beta1.services.environments.transports.base.EnvironmentsTransport]]]='grpc_asyncio',client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,client_info:google.api_core.gapic_v1.client_info.ClientInfo=Instantiates the environments async client.
See more:google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.check_upgrade
check_upgrade(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.CheckUpgradeRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationCheck if an upgrade operation on the environment willsucceed.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_folder_path
common_folder_path(folder:str)->strReturns a fully-qualified folder string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_location_path
common_location_path(project:str,location:str)->strReturns a fully-qualified location string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_organization_path
common_organization_path(organization:str)->strReturns a fully-qualified organization string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_project_path
common_project_path(project:str)->strReturns a fully-qualified project string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.create_environment
create_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.CreateEnvironmentRequest,dict,]]=None,*,parent:typing.Optional[str]=None,environment:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.Environment]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationCreate a new environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.create_user_workloads_config_map
create_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.CreateUserWorkloadsConfigMapRequest,dict,]]=None,*,parent:typing.Optional[str]=None,user_workloads_config_map:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap)Creates a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.create_user_workloads_secret
create_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.CreateUserWorkloadsSecretRequest,dict,]]=None,*,parent:typing.Optional[str]=None,user_workloads_secret:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret)Creates a user workloads Secret.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.database_failover
database_failover(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.DatabaseFailoverRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationTriggers database failover (only for highly resilientenvironments).
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.delete_environment
delete_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.DeleteEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationDelete an environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.delete_operation
delete_operation(request:typing.Optional[google.longrunning.operations_pb2.DeleteOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a long-running operation.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.delete_user_workloads_config_map
delete_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.DeleteUserWorkloadsConfigMapRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.delete_user_workloads_secret
delete_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.DeleteUserWorkloadsSecretRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a user workloads Secret.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.environment_path
environment_path(project:str,location:str,environment:str)->strReturns a fully-qualified environment string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.execute_airflow_command
execute_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ExecuteAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.ExecuteAirflowCommandResponse)Executes Airflow CLI command.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.fetch_database_properties
fetch_database_properties(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.FetchDatabasePropertiesRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.FetchDatabasePropertiesResponse)Fetches database properties.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_environment
get_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.GetEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.cloud.orchestration.airflow.service_v1beta1.types.environments.EnvironmentGet an existing environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,)Return the API endpoint and client cert source for mutual TLS.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_transport_class
get_transport_class(label:typing.Optional[str]=None,)->typing.Type[google.cloud.orchestration.airflow.service_v1beta1.services.environments.transports.base.EnvironmentsTransport]Returns an appropriate transport class.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_user_workloads_config_map
get_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.GetUserWorkloadsConfigMapRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap)Gets an existing user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_user_workloads_secret
get_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.GetUserWorkloadsSecretRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret)Gets an existing user workloads Secret.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.list_environments
list_environments(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListEnvironmentsAsyncPager)List environments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.list_operations
list_operations(request:typing.Optional[google.longrunning.operations_pb2.ListOperationsRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.list_user_workloads_config_maps
list_user_workloads_config_maps(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsConfigMapsAsyncPager)Lists user workloads ConfigMaps.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.list_user_workloads_secrets
list_user_workloads_secrets(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsSecretsAsyncPager)Lists user workloads Secrets.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.list_workloads
list_workloads(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListWorkloadsAsyncPager)Lists workloads in a Cloud Composer environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.load_snapshot
load_snapshot(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.LoadSnapshotRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationLoads a snapshot of a Cloud Composer environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_common_folder_path
parse_common_folder_path(path:str)->typing.Dict[str,str]Parse a folder path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_common_location_path
parse_common_location_path(path:str)->typing.Dict[str,str]Parse a location path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_common_organization_path
parse_common_organization_path(path:str)->typing.Dict[str,str]Parse a organization path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_common_project_path
parse_common_project_path(path:str)->typing.Dict[str,str]Parse a project path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_environment_path
parse_environment_path(path:str)->typing.Dict[str,str]Parses a environment path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_user_workloads_config_map_path
parse_user_workloads_config_map_path(path:str)->typing.Dict[str,str]Parses a user_workloads_config_map path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_user_workloads_secret_path
parse_user_workloads_secret_path(path:str)->typing.Dict[str,str]Parses a user_workloads_secret path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.poll_airflow_command
poll_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.PollAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.PollAirflowCommandResponse)Polls Airflow CLI command execution and fetches logs.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.restart_web_server
restart_web_server(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.RestartWebServerRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationRestart Airflow web server.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.save_snapshot
save_snapshot(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.SaveSnapshotRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationCreates a snapshots of a Cloud Composer environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.stop_airflow_command
stop_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.StopAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.StopAirflowCommandResponse)Stops Airflow CLI command execution.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.update_environment
update_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UpdateEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,environment:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.Environment]=None,update_mask:typing.Optional[google.protobuf.field_mask_pb2.FieldMask]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation_async.AsyncOperationUpdate an environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.update_user_workloads_config_map
update_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UpdateUserWorkloadsConfigMapRequest,dict,]]=None,*,user_workloads_config_map:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap)Updates a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.update_user_workloads_secret
update_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UpdateUserWorkloadsSecretRequest,dict,]]=None,*,user_workloads_secret:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret)Updates a user workloads Secret.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.user_workloads_config_map_path
user_workloads_config_map_path(project:str,location:str,environment:str,user_workloads_config_map:str)->strReturns a fully-qualified user_workloads_config_map string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.user_workloads_secret_path
user_workloads_secret_path(project:str,location:str,environment:str,user_workloads_secret:str)->strReturns a fully-qualified user_workloads_secret string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient
EnvironmentsClient(*,credentials:typing.Optional[google.auth.credentials.Credentials]=None,transport:typing.Optional[typing.Union[str,google.cloud.orchestration.airflow.service_v1beta1.services.environments.transports.base.EnvironmentsTransport,typing.Callable[[...],google.cloud.orchestration.airflow.service_v1beta1.services.environments.transports.base.EnvironmentsTransport]]]=None,client_options:typing.Optional[typing.Union[google.api_core.client_options.ClientOptions,dict]]=None,client_info:google.api_core.gapic_v1.client_info.ClientInfo=Instantiates the environments client.
See more:google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.__exit__
__exit__(type,value,traceback)Releases underlying transport's resources.
See more:google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.exit
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.check_upgrade
check_upgrade(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.CheckUpgradeRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationCheck if an upgrade operation on the environment willsucceed.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_folder_path
common_folder_path(folder:str)->strReturns a fully-qualified folder string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_location_path
common_location_path(project:str,location:str)->strReturns a fully-qualified location string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_organization_path
common_organization_path(organization:str)->strReturns a fully-qualified organization string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_project_path
common_project_path(project:str)->strReturns a fully-qualified project string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.create_environment
create_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.CreateEnvironmentRequest,dict,]]=None,*,parent:typing.Optional[str]=None,environment:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.Environment]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationCreate a new environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.create_user_workloads_config_map
create_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.CreateUserWorkloadsConfigMapRequest,dict,]]=None,*,parent:typing.Optional[str]=None,user_workloads_config_map:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap)Creates a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.create_user_workloads_secret
create_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.CreateUserWorkloadsSecretRequest,dict,]]=None,*,parent:typing.Optional[str]=None,user_workloads_secret:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret)Creates a user workloads Secret.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.database_failover
database_failover(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.DatabaseFailoverRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationTriggers database failover (only for highly resilientenvironments).
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.delete_environment
delete_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.DeleteEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationDelete an environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.delete_operation
delete_operation(request:typing.Optional[google.longrunning.operations_pb2.DeleteOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a long-running operation.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.delete_user_workloads_config_map
delete_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.DeleteUserWorkloadsConfigMapRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.delete_user_workloads_secret
delete_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.DeleteUserWorkloadsSecretRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a user workloads Secret.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.environment_path
environment_path(project:str,location:str,environment:str)->strReturns a fully-qualified environment string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.execute_airflow_command
execute_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ExecuteAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.ExecuteAirflowCommandResponse)Executes Airflow CLI command.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.fetch_database_properties
fetch_database_properties(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.FetchDatabasePropertiesRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.FetchDatabasePropertiesResponse)Fetches database properties.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.get_environment
get_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.GetEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.cloud.orchestration.airflow.service_v1beta1.types.environments.EnvironmentGet an existing environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,)Deprecated.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.get_user_workloads_config_map
get_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.GetUserWorkloadsConfigMapRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap)Gets an existing user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.get_user_workloads_secret
get_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.GetUserWorkloadsSecretRequest,dict,]]=None,*,name:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret)Gets an existing user workloads Secret.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.list_environments
list_environments(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListEnvironmentsPager)List environments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.list_operations
list_operations(request:typing.Optional[google.longrunning.operations_pb2.ListOperationsRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.list_user_workloads_config_maps
list_user_workloads_config_maps(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsConfigMapsPager)Lists user workloads ConfigMaps.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.list_user_workloads_secrets
list_user_workloads_secrets(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsSecretsPager)Lists user workloads Secrets.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.list_workloads
list_workloads(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListWorkloadsPager)Lists workloads in a Cloud Composer environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.load_snapshot
load_snapshot(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.LoadSnapshotRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationLoads a snapshot of a Cloud Composer environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_common_folder_path
parse_common_folder_path(path:str)->typing.Dict[str,str]Parse a folder path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_common_location_path
parse_common_location_path(path:str)->typing.Dict[str,str]Parse a location path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_common_organization_path
parse_common_organization_path(path:str)->typing.Dict[str,str]Parse a organization path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_common_project_path
parse_common_project_path(path:str)->typing.Dict[str,str]Parse a project path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_environment_path
parse_environment_path(path:str)->typing.Dict[str,str]Parses a environment path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_user_workloads_config_map_path
parse_user_workloads_config_map_path(path:str)->typing.Dict[str,str]Parses a user_workloads_config_map path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_user_workloads_secret_path
parse_user_workloads_secret_path(path:str)->typing.Dict[str,str]Parses a user_workloads_secret path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.poll_airflow_command
poll_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.PollAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.PollAirflowCommandResponse)Polls Airflow CLI command execution and fetches logs.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.restart_web_server
restart_web_server(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.RestartWebServerRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationRestart Airflow web server.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.save_snapshot
save_snapshot(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.SaveSnapshotRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationCreates a snapshots of a Cloud Composer environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.stop_airflow_command
stop_airflow_command(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.StopAirflowCommandRequest,dict,]]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.StopAirflowCommandResponse)Stops Airflow CLI command execution.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.update_environment
update_environment(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UpdateEnvironmentRequest,dict,]]=None,*,name:typing.Optional[str]=None,environment:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.Environment]=None,update_mask:typing.Optional[google.protobuf.field_mask_pb2.FieldMask]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.api_core.operation.OperationUpdate an environment.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.update_user_workloads_config_map
update_user_workloads_config_map(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UpdateUserWorkloadsConfigMapRequest,dict,]]=None,*,user_workloads_config_map:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap)Updates a user workloads ConfigMap.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.update_user_workloads_secret
update_user_workloads_secret(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UpdateUserWorkloadsSecretRequest,dict,]]=None,*,user_workloads_secret:typing.Optional[google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret)Updates a user workloads Secret.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.user_workloads_config_map_path
user_workloads_config_map_path(project:str,location:str,environment:str,user_workloads_config_map:str)->strReturns a fully-qualified user_workloads_config_map string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.user_workloads_secret_path
user_workloads_secret_path(project:str,location:str,environment:str,user_workloads_secret:str)->strReturns a fully-qualified user_workloads_secret string.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListEnvironmentsAsyncPager
ListEnvironmentsAsyncPager(method:typing.Callable[[...],typing.Awaitable[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsResponse],],request:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsRequest,response:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiates the pager.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListEnvironmentsPager
ListEnvironmentsPager(method:typing.Callable[[...],google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsResponse,],request:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsRequest,response:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiate the pager.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsConfigMapsAsyncPager
ListUserWorkloadsConfigMapsAsyncPager(method:typing.Callable[[...],typing.Awaitable[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsResponse],],request:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsRequest,response:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiates the pager.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsConfigMapsPager
ListUserWorkloadsConfigMapsPager(method:typing.Callable[[...],google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsResponse,],request:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsRequest,response:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiate the pager.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsSecretsAsyncPager
ListUserWorkloadsSecretsAsyncPager(method:typing.Callable[[...],typing.Awaitable[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsResponse],],request:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsRequest,response:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiates the pager.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsSecretsPager
ListUserWorkloadsSecretsPager(method:typing.Callable[[...],google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsResponse,],request:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsRequest,response:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiate the pager.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListWorkloadsAsyncPager
ListWorkloadsAsyncPager(method:typing.Callable[[...],typing.Awaitable[google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsResponse],],request:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsRequest,response:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiates the pager.
google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListWorkloadsPager
ListWorkloadsPager(method:typing.Callable[[...],google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsResponse,],request:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsRequest,response:google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiate the pager.
See more:google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListWorkloadsPager
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient
ImageVersionsAsyncClient(*,credentials:typing.Optional[google.auth.credentials.Credentials]=None,transport:typing.Optional[typing.Union[str,google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.transports.base.ImageVersionsTransport,typing.Callable[[...],google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.transports.base.ImageVersionsTransport]]]='grpc_asyncio',client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,client_info:google.api_core.gapic_v1.client_info.ClientInfo=Instantiates the image versions async client.
See more:google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_folder_path
common_folder_path(folder:str)->strReturns a fully-qualified folder string.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_location_path
common_location_path(project:str,location:str)->strReturns a fully-qualified location string.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_organization_path
common_organization_path(organization:str)->strReturns a fully-qualified organization string.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_project_path
common_project_path(project:str)->strReturns a fully-qualified project string.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.delete_operation
delete_operation(request:typing.Optional[google.longrunning.operations_pb2.DeleteOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a long-running operation.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,)Return the API endpoint and client cert source for mutual TLS.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.get_transport_class
get_transport_class(label:typing.Optional[str]=None,)->typing.Type[google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.transports.base.ImageVersionsTransport]Returns an appropriate transport class.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.list_image_versions
list_image_versions(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.pagers.ListImageVersionsAsyncPager)List ImageVersions for provided location.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.list_operations
list_operations(request:typing.Optional[google.longrunning.operations_pb2.ListOperationsRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.parse_common_folder_path
parse_common_folder_path(path:str)->typing.Dict[str,str]Parse a folder path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.parse_common_location_path
parse_common_location_path(path:str)->typing.Dict[str,str]Parse a location path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.parse_common_organization_path
parse_common_organization_path(path:str)->typing.Dict[str,str]Parse a organization path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.parse_common_project_path
parse_common_project_path(path:str)->typing.Dict[str,str]Parse a project path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient
ImageVersionsClient(*,credentials:typing.Optional[google.auth.credentials.Credentials]=None,transport:typing.Optional[typing.Union[str,google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.transports.base.ImageVersionsTransport,typing.Callable[[...],google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.transports.base.ImageVersionsTransport]]]=None,client_options:typing.Optional[typing.Union[google.api_core.client_options.ClientOptions,dict]]=None,client_info:google.api_core.gapic_v1.client_info.ClientInfo=Instantiates the image versions client.
See more:google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.__exit__
__exit__(type,value,traceback)Releases underlying transport's resources.
See more:google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.exit
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_folder_path
common_folder_path(folder:str)->strReturns a fully-qualified folder string.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_location_path
common_location_path(project:str,location:str)->strReturns a fully-qualified location string.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_organization_path
common_organization_path(organization:str)->strReturns a fully-qualified organization string.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_project_path
common_project_path(project:str)->strReturns a fully-qualified project string.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.delete_operation
delete_operation(request:typing.Optional[google.longrunning.operations_pb2.DeleteOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->NoneDeletes a long-running operation.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(client_options:typing.Optional[google.api_core.client_options.ClientOptions]=None,)Deprecated.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.list_image_versions
list_image_versions(request:typing.Optional[typing.Union[google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsRequest,dict,]]=None,*,parent:typing.Optional[str]=None,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->(google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.pagers.ListImageVersionsPager)List ImageVersions for provided location.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.list_operations
list_operations(request:typing.Optional[google.longrunning.operations_pb2.ListOperationsRequest]=None,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())->google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.parse_common_folder_path
parse_common_folder_path(path:str)->typing.Dict[str,str]Parse a folder path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.parse_common_location_path
parse_common_location_path(path:str)->typing.Dict[str,str]Parse a location path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.parse_common_organization_path
parse_common_organization_path(path:str)->typing.Dict[str,str]Parse a organization path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.parse_common_project_path
parse_common_project_path(path:str)->typing.Dict[str,str]Parse a project path into its component segments.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.pagers.ListImageVersionsAsyncPager
ListImageVersionsAsyncPager(method:typing.Callable[[...],typing.Awaitable[google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsResponse],],request:google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsRequest,response:google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary_async.AsyncRetry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiates the pager.
google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.pagers.ListImageVersionsPager
ListImageVersionsPager(method:typing.Callable[[...],google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsResponse,],request:google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsRequest,response:google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsResponse,*,retry:typing.Optional[typing.Union[google.api_core.retry.retry_unary.Retry,google.api_core.gapic_v1.method._MethodDefault,]]=_MethodDefault._DEFAULT_VALUE,timeout:typing.Union[float,object]=_MethodDefault._DEFAULT_VALUE,metadata:typing.Sequence[typing.Tuple[str,typing.Union[str,bytes]]]=())Instantiate the pager.
Except as otherwise noted, the content of this page is licensed under theCreative Commons Attribution 4.0 License, and code samples are licensed under theApache 2.0 License. For details, see theGoogle Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-10-30 UTC.