Package Methods (1.12.2)

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 = 

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

common_billing_account_path(billing_account: str) -> str

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

common_folder_path(folder: str) -> str

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

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

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

common_organization_path(organization: str) -> str

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

common_project_path(project: str) -> str

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

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
)

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
)

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

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

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

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

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

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

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
)

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
)

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

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

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

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

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
)

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
)

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
)

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
)

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
)

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
)

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

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]

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

parse_common_folder_path(path: str) -> typing.Dict[str, str]

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

parse_common_location_path(path: str) -> typing.Dict[str, str]

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

parse_common_organization_path(path: str) -> typing.Dict[str, str]

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

parse_common_project_path(path: str) -> typing.Dict[str, str]

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

parse_environment_path(path: str) -> typing.Dict[str, str]

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]

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]

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
)

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

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
)

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

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
)

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
)

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

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

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 = 

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

__exit__(type, value, traceback)

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

common_billing_account_path(billing_account: str) -> str

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

common_folder_path(folder: str) -> str

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

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

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

common_organization_path(organization: str) -> str

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

common_project_path(project: str) -> str

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

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
)

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
)

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

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

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

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

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

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

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
)

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
)

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

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

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

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
)

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
)

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
)

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
)

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
)

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
)

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

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]

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

parse_common_folder_path(path: str) -> typing.Dict[str, str]

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

parse_common_location_path(path: str) -> typing.Dict[str, str]

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

parse_common_organization_path(path: str) -> typing.Dict[str, str]

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

parse_common_project_path(path: str) -> typing.Dict[str, str]

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

parse_environment_path(path: str) -> typing.Dict[str, str]

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]

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]

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
)

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

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
)

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

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
)

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
)

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

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

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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 = 

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

common_billing_account_path(billing_account: str) -> str

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

common_folder_path(folder: str) -> str

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

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

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

common_organization_path(organization: str) -> str

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

common_project_path(project: str) -> str

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

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

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

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

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
)

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]

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

parse_common_folder_path(path: str) -> typing.Dict[str, str]

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

parse_common_location_path(path: str) -> typing.Dict[str, str]

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

parse_common_organization_path(path: str) -> typing.Dict[str, str]

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

parse_common_project_path(path: str) -> typing.Dict[str, str]

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 = 

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

__exit__(type, value, traceback)

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

common_billing_account_path(billing_account: str) -> str

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

common_folder_path(folder: str) -> str

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

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

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

common_organization_path(organization: str) -> str

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

common_project_path(project: str) -> str

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

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

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

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
)

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]

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

parse_common_folder_path(path: str) -> typing.Dict[str, str]

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

parse_common_location_path(path: str) -> typing.Dict[str, str]

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

parse_common_organization_path(path: str) -> typing.Dict[str, str]

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

parse_common_project_path(path: str) -> typing.Dict[str, str]

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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 = 

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

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

common_folder_path(folder: str) -> str

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

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

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

common_organization_path(organization: str) -> str

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

common_project_path(project: str) -> str

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

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
)

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
)

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

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

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

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

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

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

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
)

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
)

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

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

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

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

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
)

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
)

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
)

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
)

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
)

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
)

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

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]

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

parse_common_folder_path(path: str) -> typing.Dict[str, str]

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

parse_common_location_path(path: str) -> typing.Dict[str, str]

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

parse_common_organization_path(path: str) -> typing.Dict[str, str]

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

parse_common_project_path(path: str) -> typing.Dict[str, str]

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

parse_environment_path(path: str) -> typing.Dict[str, str]

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]

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]

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
)

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

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

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
)

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

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
)

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
)

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

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

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 = 

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

__exit__(type, value, traceback)

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

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

common_folder_path(folder: str) -> str

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

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

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

common_organization_path(organization: str) -> str

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

common_project_path(project: str) -> str

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

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
)

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
)

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

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

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

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

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

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

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
)

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
)

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

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

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

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
)

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
)

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
)

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
)

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
)

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
)

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

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]

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

parse_common_folder_path(path: str) -> typing.Dict[str, str]

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

parse_common_location_path(path: str) -> typing.Dict[str, str]

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

parse_common_organization_path(path: str) -> typing.Dict[str, str]

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

parse_common_project_path(path: str) -> typing.Dict[str, str]

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

parse_environment_path(path: str) -> typing.Dict[str, str]

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]

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]

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
)

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

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

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
)

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

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
)

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
)

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

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

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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 = 

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

common_billing_account_path(billing_account: str) -> str

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

common_folder_path(folder: str) -> str

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

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

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

common_organization_path(organization: str) -> str

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

common_project_path(project: str) -> str

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

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

from_service_account_file(filename: str, *args, **kwargs)

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

from_service_account_info(info: dict, *args, **kwargs)

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

from_service_account_json(filename: str, *args, **kwargs)

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

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

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

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
)

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

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]

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

parse_common_folder_path(path: str) -> typing.Dict[str, str]

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

parse_common_location_path(path: str) -> typing.Dict[str, str]

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

parse_common_organization_path(path: str) -> typing.Dict[str, str]

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

parse_common_project_path(path: str) -> typing.Dict[str, str]

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 = 

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

__exit__(type, value, traceback)

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

common_billing_account_path(billing_account: str) -> str

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

common_folder_path(folder: str) -> str

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

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

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

common_organization_path(organization: str) -> str

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

common_project_path(project: str) -> str

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

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

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

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
)

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]

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

parse_common_folder_path(path: str) -> typing.Dict[str, str]

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

parse_common_location_path(path: str) -> typing.Dict[str, str]

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

parse_common_organization_path(path: str) -> typing.Dict[str, str]

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

parse_common_project_path(path: str) -> typing.Dict[str, str]

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

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,
    *,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)