Package Methods (1.13.1)

Version 1.13.1

• 1.15.1 (latest)
• 1.15.0
• 1.14.0
• 1.13.1
• 1.12.2
• 1.11.1
• 1.10.0
• 1.9.1
• 1.8.0
• 1.7.1
• 1.6.1
• 1.5.0
• 1.4.4
• 1.3.2
• 1.2.1
• 1.1.0
• 1.0.0
• 0.1.3

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.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_billing_account_path

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_folder_path

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_location_path

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_organization_path

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.common_project_path

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Create a new environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.create_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap
)

Creates a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.create_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret
)

Creates a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.create_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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Triggers database failover (only for highly resilient environments).

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.database_failover

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Delete an environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.delete_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, str]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.delete_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, str]] = ()
) -> None

Deletes a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.delete_user_workloads_config_map

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, str]] = ()
) -> None

Deletes a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.delete_user_workloads_secret

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.environment_path

environment_path(project: str, location: str, environment: str) -> str

Returns a fully-qualified environment string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.environment_path

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.ExecuteAirflowCommandResponse
)

Executes Airflow CLI command.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.execute_airflow_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.FetchDatabasePropertiesResponse
)

Fetches database properties.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.fetch_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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.from_service_account_json

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, str]] = ()
) -> google.cloud.orchestration.airflow.service_v1.types.environments.Environment

Get an existing environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_mtls_endpoint_and_cert_source

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, str]] = ()
) -> google.longrunning.operations_pb2.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_operation

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_transport_class

get_transport_class() -> (
    typing.Type[
        google.cloud.orchestration.airflow.service_v1.services.environments.transports.base.EnvironmentsTransport
    ]
)

Returns an appropriate transport class.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap
)

Gets an existing user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret
)

Gets an existing user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListEnvironmentsAsyncPager
)

List environments.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.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, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.list_operations

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsConfigMapsAsyncPager
)

Lists user workloads ConfigMaps.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.list_user_workloads_config_maps

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsSecretsAsyncPager
)

Lists user workloads Secrets.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.list_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListWorkloadsAsyncPager
)

Lists workloads in a Cloud Composer environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.list_workloads

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Loads a snapshot of a Cloud Composer environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.load_snapshot

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_common_folder_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_common_location_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_common_organization_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_common_project_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_environment_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_user_workloads_config_map_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.parse_user_workloads_secret_path

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.PollAirflowCommandResponse
)

Polls Airflow CLI command execution and fetches logs.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.poll_airflow_command

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Creates a snapshots of a Cloud Composer environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.save_snapshot

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.StopAirflowCommandResponse
)

Stops Airflow CLI command execution.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.stop_airflow_command

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Update an environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.update_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap
)

Updates a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.update_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret
)

Updates a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.update_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
) -> str

Returns a fully-qualified user_workloads_config_map string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.user_workloads_config_map_path

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
) -> str

Returns a fully-qualified user_workloads_secret string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsAsyncClient.user_workloads_secret_path

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.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_billing_account_path

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_folder_path

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_location_path

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_organization_path

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.common_project_path

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, str]] = ()
) -> google.api_core.operation.Operation

Create a new environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.create_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap
)

Creates a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.create_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret
)

Creates a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.create_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, str]] = ()
) -> google.api_core.operation.Operation

Triggers database failover (only for highly resilient environments).

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.database_failover

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, str]] = ()
) -> google.api_core.operation.Operation

Delete an environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.delete_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, str]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.delete_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, str]] = ()
) -> None

Deletes a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.delete_user_workloads_config_map

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, str]] = ()
) -> None

Deletes a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.delete_user_workloads_secret

google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.environment_path

environment_path(project: str, location: str, environment: str) -> str

Returns a fully-qualified environment string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.environment_path

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.ExecuteAirflowCommandResponse
)

Executes Airflow CLI command.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.execute_airflow_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.FetchDatabasePropertiesResponse
)

Fetches database properties.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.fetch_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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.from_service_account_json

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, str]] = ()
) -> google.cloud.orchestration.airflow.service_v1.types.environments.Environment

Get an existing environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.get_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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.get_mtls_endpoint_and_cert_source

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, str]] = ()
) -> google.longrunning.operations_pb2.Operation

Gets 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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap
)

Gets an existing user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.get_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret
)

Gets an existing user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListEnvironmentsPager
)

List environments.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.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, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.list_operations

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsConfigMapsPager
)

Lists user workloads ConfigMaps.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.list_user_workloads_config_maps

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsSecretsPager
)

Lists user workloads Secrets.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.list_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListWorkloadsPager
)

Lists workloads in a Cloud Composer environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.list_workloads

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, str]] = ()
) -> google.api_core.operation.Operation

Loads 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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_common_billing_account_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_common_folder_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_common_location_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_common_organization_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_common_project_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_environment_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_user_workloads_config_map_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.parse_user_workloads_secret_path

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.PollAirflowCommandResponse
)

Polls Airflow CLI command execution and fetches logs.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.poll_airflow_command

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, str]] = ()
) -> google.api_core.operation.Operation

Creates 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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.StopAirflowCommandResponse
)

Stops Airflow CLI command execution.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.stop_airflow_command

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, str]] = ()
) -> google.api_core.operation.Operation

Update an environment.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.update_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap
)

Updates a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.update_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret
)

Updates a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.update_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
) -> str

Returns a fully-qualified user_workloads_config_map string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.user_workloads_config_map_path

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
) -> str

Returns a fully-qualified user_workloads_secret string.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.EnvironmentsClient.user_workloads_secret_path

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, str]] = ()
)

Instantiates the pager.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListEnvironmentsAsyncPager

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, str]] = ()
)

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, str]] = ()
)

Instantiates the pager.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsConfigMapsAsyncPager

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, str]] = ()
)

Instantiate the pager.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsConfigMapsPager

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, str]] = ()
)

Instantiates the pager.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsSecretsAsyncPager

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, str]] = ()
)

Instantiate the pager.

See more: google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsSecretsPager

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, str]] = ()
)

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, str]] = ()
)

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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_billing_account_path

google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_folder_path

google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_location_path

google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_organization_path

google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.common_project_path

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, str]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.delete_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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.from_service_account_json

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.get_mtls_endpoint_and_cert_source

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, str]] = ()
) -> google.longrunning.operations_pb2.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.get_operation

google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.get_transport_class

get_transport_class() -> (
    typing.Type[
        google.cloud.orchestration.airflow.service_v1.services.image_versions.transports.base.ImageVersionsTransport
    ]
)

Returns an appropriate transport class.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.image_versions.pagers.ListImageVersionsAsyncPager
)

List ImageVersions for provided location.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.list_image_versions

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, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.list_operations

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.parse_common_folder_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.parse_common_location_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.parse_common_organization_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsAsyncClient.parse_common_project_path

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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_billing_account_path

google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_folder_path

google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_location_path

google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_organization_path

google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.common_project_path

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, str]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.delete_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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.from_service_account_json

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.get_mtls_endpoint_and_cert_source

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, str]] = ()
) -> google.longrunning.operations_pb2.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.image_versions.pagers.ListImageVersionsPager
)

List ImageVersions for provided location.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.list_image_versions

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, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.list_operations

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.parse_common_billing_account_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.parse_common_folder_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.parse_common_location_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.parse_common_organization_path

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.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.ImageVersionsClient.parse_common_project_path

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, str]] = ()
)

Instantiates the pager.

See more: google.cloud.orchestration.airflow.service_v1.services.image_versions.pagers.ListImageVersionsAsyncPager

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, str]] = ()
)

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Check if an upgrade operation on the environment will succeed.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.check_upgrade

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_billing_account_path

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_folder_path

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_location_path

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_organization_path

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.common_project_path

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Create a new environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.create_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap
)

Creates a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.create_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret
)

Creates a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.create_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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Triggers database failover (only for highly resilient environments).

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.database_failover

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Delete an environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.delete_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, str]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.delete_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, str]] = ()
) -> None

Deletes a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.delete_user_workloads_config_map

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, str]] = ()
) -> None

Deletes a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.delete_user_workloads_secret

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.environment_path

environment_path(project: str, location: str, environment: str) -> str

Returns a fully-qualified environment string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.environment_path

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.ExecuteAirflowCommandResponse
)

Executes Airflow CLI command.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.execute_airflow_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.FetchDatabasePropertiesResponse
)

Fetches database properties.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.fetch_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.from_service_account_json

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, str]] = ()
) -> google.cloud.orchestration.airflow.service_v1beta1.types.environments.Environment

Get an existing environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_mtls_endpoint_and_cert_source

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, str]] = ()
) -> google.longrunning.operations_pb2.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_operation

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_transport_class

get_transport_class() -> (
    typing.Type[
        google.cloud.orchestration.airflow.service_v1beta1.services.environments.transports.base.EnvironmentsTransport
    ]
)

Returns an appropriate transport class.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap
)

Gets an existing user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret
)

Gets an existing user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListEnvironmentsAsyncPager
)

List environments.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.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, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.list_operations

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsConfigMapsAsyncPager
)

Lists user workloads ConfigMaps.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.list_user_workloads_config_maps

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsSecretsAsyncPager
)

Lists user workloads Secrets.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.list_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListWorkloadsAsyncPager
)

Lists workloads in a Cloud Composer environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.list_workloads

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Loads a snapshot of a Cloud Composer environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.load_snapshot

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_common_folder_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_common_location_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_common_organization_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_common_project_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_environment_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_user_workloads_config_map_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.parse_user_workloads_secret_path

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.PollAirflowCommandResponse
)

Polls Airflow CLI command execution and fetches logs.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.poll_airflow_command

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Restart Airflow web server.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.restart_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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Creates a snapshots of a Cloud Composer environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.save_snapshot

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.StopAirflowCommandResponse
)

Stops Airflow CLI command execution.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.stop_airflow_command

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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Update an environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.update_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap
)

Updates a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.update_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret
)

Updates a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.update_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
) -> str

Returns a fully-qualified user_workloads_config_map string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.user_workloads_config_map_path

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
) -> str

Returns a fully-qualified user_workloads_secret string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsAsyncClient.user_workloads_secret_path

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, str]] = ()
) -> google.api_core.operation.Operation

Check if an upgrade operation on the environment will succeed.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.check_upgrade

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_billing_account_path

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_folder_path

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_location_path

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_organization_path

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.common_project_path

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, str]] = ()
) -> google.api_core.operation.Operation

Create a new environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.create_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap
)

Creates a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.create_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret
)

Creates a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.create_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, str]] = ()
) -> google.api_core.operation.Operation

Triggers database failover (only for highly resilient environments).

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.database_failover

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, str]] = ()
) -> google.api_core.operation.Operation

Delete an environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.delete_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, str]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.delete_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, str]] = ()
) -> None

Deletes a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.delete_user_workloads_config_map

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, str]] = ()
) -> None

Deletes a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.delete_user_workloads_secret

google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.environment_path

environment_path(project: str, location: str, environment: str) -> str

Returns a fully-qualified environment string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.environment_path

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.ExecuteAirflowCommandResponse
)

Executes Airflow CLI command.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.execute_airflow_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.FetchDatabasePropertiesResponse
)

Fetches database properties.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.fetch_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.from_service_account_json

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, str]] = ()
) -> google.cloud.orchestration.airflow.service_v1beta1.types.environments.Environment

Get an existing environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.get_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.get_mtls_endpoint_and_cert_source

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, str]] = ()
) -> google.longrunning.operations_pb2.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap
)

Gets an existing user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.get_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret
)

Gets an existing user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListEnvironmentsPager
)

List environments.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.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, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.list_operations

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsConfigMapsPager
)

Lists user workloads ConfigMaps.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.list_user_workloads_config_maps

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsSecretsPager
)

Lists user workloads Secrets.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.list_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListWorkloadsPager
)

Lists workloads in a Cloud Composer environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.list_workloads

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, str]] = ()
) -> google.api_core.operation.Operation

Loads a snapshot of a Cloud Composer environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.load_snapshot

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_common_billing_account_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_common_folder_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_common_location_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_common_organization_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_common_project_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_environment_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_user_workloads_config_map_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.parse_user_workloads_secret_path

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.PollAirflowCommandResponse
)

Polls Airflow CLI command execution and fetches logs.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.poll_airflow_command

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, str]] = ()
) -> google.api_core.operation.Operation

Restart Airflow web server.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.restart_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, str]] = ()
) -> google.api_core.operation.Operation

Creates a snapshots of a Cloud Composer environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.save_snapshot

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.StopAirflowCommandResponse
)

Stops Airflow CLI command execution.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.stop_airflow_command

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, str]] = ()
) -> google.api_core.operation.Operation

Update an environment.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.update_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap
)

Updates a user workloads ConfigMap.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.update_user_workloads_config_map

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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret
)

Updates a user workloads Secret.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.update_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
) -> str

Returns a fully-qualified user_workloads_config_map string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.user_workloads_config_map_path

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
) -> str

Returns a fully-qualified user_workloads_secret string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.EnvironmentsClient.user_workloads_secret_path

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, str]] = ()
)

Instantiates the pager.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListEnvironmentsAsyncPager

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, str]] = ()
)

Instantiate the pager.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListEnvironmentsPager

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, str]] = ()
)

Instantiates the pager.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsConfigMapsAsyncPager

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, str]] = ()
)

Instantiate the pager.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsConfigMapsPager

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, str]] = ()
)

Instantiates the pager.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsSecretsAsyncPager

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, str]] = ()
)

Instantiate the pager.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsSecretsPager

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, str]] = ()
)

Instantiates the pager.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListWorkloadsAsyncPager

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, str]] = ()
)

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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_billing_account_path

google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_folder_path

google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_location_path

google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_organization_path

google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.common_project_path

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, str]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.delete_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.from_service_account_json

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.get_mtls_endpoint_and_cert_source

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, str]] = ()
) -> google.longrunning.operations_pb2.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.get_operation

google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.get_transport_class

get_transport_class() -> (
    typing.Type[
        google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.transports.base.ImageVersionsTransport
    ]
)

Returns an appropriate transport class.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.pagers.ListImageVersionsAsyncPager
)

List ImageVersions for provided location.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.list_image_versions

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, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.list_operations

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.parse_common_folder_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.parse_common_location_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.parse_common_organization_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsAsyncClient.parse_common_project_path

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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_billing_account_path

google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_folder_path

google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_location_path

google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_organization_path

google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.common_project_path

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, str]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.delete_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.from_service_account_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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.from_service_account_json

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.get_mtls_endpoint_and_cert_source

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, str]] = ()
) -> google.longrunning.operations_pb2.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.get_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, str]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.pagers.ListImageVersionsPager
)

List ImageVersions for provided location.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.list_image_versions

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, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.list_operations

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.parse_common_billing_account_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.parse_common_folder_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.parse_common_location_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.parse_common_organization_path

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.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.ImageVersionsClient.parse_common_project_path

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, str]] = ()
)

Instantiates the pager.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.pagers.ListImageVersionsAsyncPager

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, str]] = ()
)

Instantiate the pager.

See more: google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.pagers.ListImageVersionsPager