Package Methods (1.17.5) (original) (raw)

Documentation
- Overview
- Guides
- Reference
- Samples
Technology areas
Cross-product tools
Related sites
Console
Contact Us
Start free
Overview
Library reference docs
BigQuery DataFrames
google-cloud-aiplatform
google-cloud-asset
google-cloud-bigquery-storage
google-cloud-bigtable
google-cloud-chronicle
google-cloud-compute
google-cloud-datacatalog
google-cloud-dataplex
google-cloud-documentai
google-cloud-financialservices
google-cloud-gdchardwaremanagement
google-cloud-gke-backup
google-cloud-logging
google-cloud-lustre
google-cloud-modelarmor
google-cloud-netapp
google-cloud-orchestration-airflow
- Overview
- Changelog
- Multiprocessing
- Orchestration
  * service_v1.environments
  * Overview
  * pagers
  * Overview
  * ListEnvironmentsAsyncPager
  * ListEnvironmentsPager
  * ListUserWorkloadsConfigMapsAsyncPager
  * ListUserWorkloadsConfigMapsPager
  * ListUserWorkloadsSecretsAsyncPager
  * ListUserWorkloadsSecretsPager
  * ListWorkloadsAsyncPager
  * ListWorkloadsPager
  * EnvironmentsAsyncClient
  * EnvironmentsClient
  * service_v1.types
  * Overview
  * CheckUpgradeRequest
  * CloudDataLineageIntegration
  * CreateEnvironmentRequest
  * CreateUserWorkloadsConfigMapRequest
  * CreateUserWorkloadsSecretRequest
  * DataRetentionConfig
  * DatabaseConfig
  * DatabaseFailoverRequest
  * DatabaseFailoverResponse
  * DeleteEnvironmentRequest
  * DeleteUserWorkloadsConfigMapRequest
  * DeleteUserWorkloadsSecretRequest
  * EncryptionConfig
  * ExecuteAirflowCommandRequest
  * ExecuteAirflowCommandResponse
  * FetchDatabasePropertiesRequest
  * FetchDatabasePropertiesResponse
  * GetEnvironmentRequest
  * GetUserWorkloadsConfigMapRequest
  * GetUserWorkloadsSecretRequest
  * IPAllocationPolicy
  * ImageVersion
  * ListEnvironmentsRequest
  * ListEnvironmentsResponse
  * ListImageVersionsRequest
  * ListImageVersionsResponse
  * ListUserWorkloadsConfigMapsRequest
  * ListUserWorkloadsConfigMapsResponse
  * ListUserWorkloadsSecretsRequest
  * ListUserWorkloadsSecretsResponse
  * ListWorkloadsRequest
  * LoadSnapshotRequest
  * LoadSnapshotResponse
  * MaintenanceWindow
  * NodeConfig
  * PollAirflowCommandRequest
  * PrivateClusterConfig
  * PrivateEnvironmentConfig
  * RecoveryConfig
  * SaveSnapshotRequest
  * SaveSnapshotResponse
  * ScheduledSnapshotsConfig
  * StopAirflowCommandRequest
  * StopAirflowCommandResponse
  * StorageConfig
  * UpdateEnvironmentRequest
  * UpdateUserWorkloadsConfigMapRequest
  * UpdateUserWorkloadsSecretRequest
  * WebServerConfig
  * service_v1beta1.environments
  * Overview
  * pagers
  * Overview
  * ListEnvironmentsAsyncPager
  * ListEnvironmentsPager
  * ListUserWorkloadsConfigMapsAsyncPager
  * ListUserWorkloadsConfigMapsPager
  * ListUserWorkloadsSecretsAsyncPager
  * ListUserWorkloadsSecretsPager
  * ListWorkloadsAsyncPager
  * ListWorkloadsPager
  * EnvironmentsAsyncClient
  * EnvironmentsClient
  * service_v1beta1.types
  * Overview
  * CheckUpgradeRequest
  * CloudDataLineageIntegration
  * CreateEnvironmentRequest
  * CreateUserWorkloadsConfigMapRequest
  * CreateUserWorkloadsSecretRequest
  * DataRetentionConfig
  * DatabaseConfig
  * DatabaseFailoverRequest
  * DatabaseFailoverResponse
  * DeleteEnvironmentRequest
  * DeleteUserWorkloadsConfigMapRequest
  * DeleteUserWorkloadsSecretRequest
  * EncryptionConfig
  * ExecuteAirflowCommandRequest
  * ExecuteAirflowCommandResponse
  * FetchDatabasePropertiesRequest
  * FetchDatabasePropertiesResponse
  * GetEnvironmentRequest
  * GetUserWorkloadsConfigMapRequest
  * GetUserWorkloadsSecretRequest
  * IPAllocationPolicy
  * ImageVersion
  * ListEnvironmentsRequest
  * ListEnvironmentsResponse
  * ListImageVersionsRequest
  * ListImageVersionsResponse
  * ListUserWorkloadsConfigMapsRequest
  * ListUserWorkloadsConfigMapsResponse
  * ListUserWorkloadsSecretsRequest
  * ListUserWorkloadsSecretsResponse
  * ListWorkloadsRequest
  * LoadSnapshotRequest
  * LoadSnapshotResponse
  * MaintenanceWindow
  * NodeConfig
  * PollAirflowCommandRequest
  * PrivateClusterConfig
  * PrivateEnvironmentConfig
  * RecoveryConfig
  * RestartWebServerRequest
  * SaveSnapshotRequest
  * SaveSnapshotResponse
  * ScheduledSnapshotsConfig
  * StopAirflowCommandRequest
  * StopAirflowCommandResponse
  * StorageConfig
  * UpdateEnvironmentRequest
  * UpdateUserWorkloadsConfigMapRequest
  * UpdateUserWorkloadsSecretRequest
  * WebServerConfig
google-cloud-org-policy
google-cloud-retail
google-cloud-secret-manager
google-cloud-spanner
google-cloud-storagebatchoperations

Package Methods (1.17.5)

Stay organized with collections Save and categorize content based on your preferences.

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

check_upgrade(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.CheckUpgradeRequest,
            dict,
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

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

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

delete_environment(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.DeleteEnvironmentRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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)

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

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

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

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

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

get_environment(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.GetEnvironmentRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.orchestration.airflow.service_v1.types.environments.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, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.Operation

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

get_transport_class(
    label: typing.Optional[str] = None,
) -> typing.Type[
    google.cloud.orchestration.airflow.service_v1.services.environments.transports.base.EnvironmentsTransport
]

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

get_user_workloads_config_map(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.GetUserWorkloadsConfigMapRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsConfigMap
)

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

get_user_workloads_secret(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.GetUserWorkloadsSecretRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.types.environments.UserWorkloadsSecret
)

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

list_environments(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListEnvironmentsAsyncPager
)

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

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

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

list_user_workloads_config_maps(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsConfigMapsAsyncPager
)

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

list_user_workloads_secrets(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsSecretsAsyncPager
)

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

list_workloads(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListWorkloadsAsyncPager
)

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

load_snapshot(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.LoadSnapshotRequest,
            dict,
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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.check_upgrade

check_upgrade(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.CheckUpgradeRequest,
            dict,
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

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

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

delete_environment(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.DeleteEnvironmentRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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)

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

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

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

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

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

get_environment(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.GetEnvironmentRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.orchestration.airflow.service_v1.types.environments.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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

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

list_user_workloads_config_maps(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsConfigMapsPager
)

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

list_user_workloads_secrets(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListUserWorkloadsSecretsPager
)

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

list_workloads(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.environments.pagers.ListWorkloadsPager
)

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

load_snapshot(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.environments.LoadSnapshotRequest,
            dict,
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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

ListEnvironmentsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsResponse
        ],
    ],
    request: google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsRequest,
    response: google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListEnvironmentsPager(
    method: typing.Callable[
        [...],
        google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsResponse,
    ],
    request: google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsRequest,
    response: google.cloud.orchestration.airflow.service_v1.types.environments.ListEnvironmentsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListUserWorkloadsConfigMapsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsResponse
        ],
    ],
    request: google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsRequest,
    response: google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListUserWorkloadsConfigMapsPager(
    method: typing.Callable[
        [...],
        google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsResponse,
    ],
    request: google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsRequest,
    response: google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsConfigMapsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListUserWorkloadsSecretsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsResponse
        ],
    ],
    request: google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsRequest,
    response: google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListUserWorkloadsSecretsPager(
    method: typing.Callable[
        [...],
        google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsResponse,
    ],
    request: google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsRequest,
    response: google.cloud.orchestration.airflow.service_v1.types.environments.ListUserWorkloadsSecretsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListWorkloadsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsResponse
        ],
    ],
    request: google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsRequest,
    response: google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListWorkloadsPager(
    method: typing.Callable[
        [...],
        google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsResponse,
    ],
    request: google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsRequest,
    response: google.cloud.orchestration.airflow.service_v1.types.environments.ListWorkloadsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

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, typing.Union[str, bytes]]] = ()
) -> None

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

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

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

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

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

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

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

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

get_transport_class(
    label: typing.Optional[str] = None,
) -> typing.Type[
    google.cloud.orchestration.airflow.service_v1.services.image_versions.transports.base.ImageVersionsTransport
]

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

list_image_versions(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1.services.image_versions.pagers.ListImageVersionsAsyncPager
)

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

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

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, typing.Union[str, bytes]]] = ()
) -> None

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

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

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

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

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

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

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

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]

ListImageVersionsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsResponse
        ],
    ],
    request: google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsRequest,
    response: google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListImageVersionsPager(
    method: typing.Callable[
        [...],
        google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsResponse,
    ],
    request: google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsRequest,
    response: google.cloud.orchestration.airflow.service_v1.types.image_versions.ListImageVersionsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

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

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

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

delete_environment(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.DeleteEnvironmentRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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)

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

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

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

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

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

get_environment(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.GetEnvironmentRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.orchestration.airflow.service_v1beta1.types.environments.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, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.Operation

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

get_transport_class(
    label: typing.Optional[str] = None,
) -> typing.Type[
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.transports.base.EnvironmentsTransport
]

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

get_user_workloads_config_map(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.GetUserWorkloadsConfigMapRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsConfigMap
)

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

get_user_workloads_secret(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.GetUserWorkloadsSecretRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.types.environments.UserWorkloadsSecret
)

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

list_environments(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListEnvironmentsAsyncPager
)

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

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

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

list_user_workloads_config_maps(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsConfigMapsAsyncPager
)

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

list_user_workloads_secrets(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsSecretsAsyncPager
)

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

list_workloads(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListWorkloadsAsyncPager
)

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

load_snapshot(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.LoadSnapshotRequest,
            dict,
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

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

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

delete_environment(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.DeleteEnvironmentRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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)

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

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

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

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

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

get_environment(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.GetEnvironmentRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.orchestration.airflow.service_v1beta1.types.environments.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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

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

list_user_workloads_config_maps(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsConfigMapsPager
)

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

list_user_workloads_secrets(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListUserWorkloadsSecretsPager
)

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

list_workloads(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.environments.pagers.ListWorkloadsPager
)

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

load_snapshot(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.LoadSnapshotRequest,
            dict,
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> 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, typing.Union[str, bytes]]] = ()
) -> (
    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, typing.Union[str, bytes]]] = ()
) -> (
    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

ListEnvironmentsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsResponse
        ],
    ],
    request: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsRequest,
    response: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListEnvironmentsPager(
    method: typing.Callable[
        [...],
        google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsResponse,
    ],
    request: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsRequest,
    response: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListEnvironmentsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListUserWorkloadsConfigMapsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsResponse
        ],
    ],
    request: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsRequest,
    response: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListUserWorkloadsConfigMapsPager(
    method: typing.Callable[
        [...],
        google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsResponse,
    ],
    request: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsRequest,
    response: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsConfigMapsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListUserWorkloadsSecretsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsResponse
        ],
    ],
    request: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsRequest,
    response: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListUserWorkloadsSecretsPager(
    method: typing.Callable[
        [...],
        google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsResponse,
    ],
    request: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsRequest,
    response: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListUserWorkloadsSecretsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListWorkloadsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsResponse
        ],
    ],
    request: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsRequest,
    response: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListWorkloadsPager(
    method: typing.Callable[
        [...],
        google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsResponse,
    ],
    request: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsRequest,
    response: google.cloud.orchestration.airflow.service_v1beta1.types.environments.ListWorkloadsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

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

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

get_transport_class(
    label: typing.Optional[str] = None,
) -> typing.Type[
    google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.transports.base.ImageVersionsTransport
]

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

list_image_versions(
    request: typing.Optional[
        typing.Union[
            google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.orchestration.airflow.service_v1beta1.services.image_versions.pagers.ListImageVersionsAsyncPager
)

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

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.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, typing.Union[str, bytes]]] = ()
) -> None

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

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

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

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

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

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

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

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]

ListImageVersionsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsResponse
        ],
    ],
    request: google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsRequest,
    response: google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

ListImageVersionsPager(
    method: typing.Callable[
        [...],
        google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsResponse,
    ],
    request: google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsRequest,
    response: google.cloud.orchestration.airflow.service_v1beta1.types.image_versions.ListImageVersionsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2025-05-02 UTC.