# Path: google/cloud/orchestration/airflow/service_v1beta1/types/environments.py
# class CreateEnvironmentRequest(proto.Message):
# class GetEnvironmentRequest(proto.Message):
# class ListEnvironmentsRequest(proto.Message):
# class ListEnvironmentsResponse(proto.Message):
# class DeleteEnvironmentRequest(proto.Message):
# class UpdateEnvironmentRequest(proto.Message):
# class RestartWebServerRequest(proto.Message):
# class EnvironmentConfig(proto.Message):
#     class EnvironmentSize(proto.Enum):
# class WebServerNetworkAccessControl(proto.Message):
#     class AllowedIpRange(proto.Message):
# class SoftwareConfig(proto.Message):
# class IPAllocationPolicy(proto.Message):
# class NodeConfig(proto.Message):
# class PrivateClusterConfig(proto.Message):
# class PrivateEnvironmentConfig(proto.Message):
# class DatabaseConfig(proto.Message):
# class WebServerConfig(proto.Message):
# class EncryptionConfig(proto.Message):
# class MaintenanceWindow(proto.Message):
# class WorkloadsConfig(proto.Message):
#     class SchedulerResource(proto.Message):
#     class WebServerResource(proto.Message):
#     class WorkerResource(proto.Message):
# class Environment(proto.Message):
#     class State(proto.Enum):
# class CheckUpgradeRequest(proto.Message):
# class CheckUpgradeResponse(proto.Message):
#     class ConflictResult(proto.Enum):
#     def raw_page(self):
#         ENVIRONMENT_SIZE_UNSPECIFIED = 0
#         ENVIRONMENT_SIZE_SMALL = 1
#         ENVIRONMENT_SIZE_MEDIUM = 2
#         ENVIRONMENT_SIZE_LARGE = 3
#         STATE_UNSPECIFIED = 0
#         CREATING = 1
#         RUNNING = 2
#         UPDATING = 3
#         DELETING = 4
#         ERROR = 5
#         CONFLICT_RESULT_UNSPECIFIED = 0
#         CONFLICT = 1
#         NO_CONFLICT = 2


import abc
import pkg_resources
import google.auth  # type: ignore
import google.api_core
from typing import Awaitable, Callable, Dict, Optional, Sequence, Union
from google.api_core import exceptions as core_exceptions
from google.api_core import gapic_v1
from google.api_core import retry as retries
from google.api_core import operations_v1
from google.auth import credentials as ga_credentials  # type: ignore
from google.oauth2 import service_account  # type: ignore
from google.cloud.orchestration.airflow.service_v1beta1.types import environments
from google.longrunning import operations_pb2  # type: ignore
        [environments.ListEnvironmentsRequest],
        Union[
            environments.ListEnvironmentsResponse,
            Awaitable[environments.ListEnvironmentsResponse],
        ],
    ]:
        raise NotImplementedError()

    @property
    def update_environment(
        self,
    ) -> Callable[
        [environments.UpdateEnvironmentRequest],
        Union[operations_pb2.Operation, Awaitable[operations_pb2.Operation]],
    ]:
        raise NotImplementedError()

    @property
    def delete_environment(
        self,
    ) -> Callable[
        [environments.DeleteEnvironmentRequest],
        Union[operations_pb2.Operation, Awaitable[operations_pb2.Operation]],
    ]:
        raise NotImplementedError()

    @property
    def restart_web_server(
        self,
    ) -> Callable[

# Path: google/cloud/orchestration/airflow/service_v1beta1/types/environments.py
# class CreateEnvironmentRequest(proto.Message):
# class GetEnvironmentRequest(proto.Message):
# class ListEnvironmentsRequest(proto.Message):
# class ListEnvironmentsResponse(proto.Message):
# class DeleteEnvironmentRequest(proto.Message):
# class UpdateEnvironmentRequest(proto.Message):
# class RestartWebServerRequest(proto.Message):
# class EnvironmentConfig(proto.Message):
#     class EnvironmentSize(proto.Enum):
# class WebServerNetworkAccessControl(proto.Message):
#     class AllowedIpRange(proto.Message):
# class SoftwareConfig(proto.Message):
# class IPAllocationPolicy(proto.Message):
# class NodeConfig(proto.Message):
# class PrivateClusterConfig(proto.Message):
# class PrivateEnvironmentConfig(proto.Message):
# class DatabaseConfig(proto.Message):
# class WebServerConfig(proto.Message):
# class EncryptionConfig(proto.Message):
# class MaintenanceWindow(proto.Message):
# class WorkloadsConfig(proto.Message):
#     class SchedulerResource(proto.Message):
#     class WebServerResource(proto.Message):
#     class WorkerResource(proto.Message):
# class Environment(proto.Message):
#     class State(proto.Enum):
# class CheckUpgradeRequest(proto.Message):
# class CheckUpgradeResponse(proto.Message):
#     class ConflictResult(proto.Enum):
#     def raw_page(self):
#         ENVIRONMENT_SIZE_UNSPECIFIED = 0
#         ENVIRONMENT_SIZE_SMALL = 1
#         ENVIRONMENT_SIZE_MEDIUM = 2
#         ENVIRONMENT_SIZE_LARGE = 3
#         STATE_UNSPECIFIED = 0
#         CREATING = 1
#         RUNNING = 2
#         UPDATING = 3
#         DELETING = 4
#         ERROR = 5
#         CONFLICT_RESULT_UNSPECIFIED = 0
#         CONFLICT = 1
#         NO_CONFLICT = 2


# Path: google/cloud/orchestration/airflow/service_v1beta1/services/environments/transports/base.py
import abc
import pkg_resources
import google.auth  # type: ignore
import google.api_core
from typing import Awaitable, Callable, Dict, Optional, Sequence, Union
from google.api_core import exceptions as core_exceptions
from google.api_core import gapic_v1
from google.api_core import retry as retries
from google.api_core import operations_v1
from google.auth import credentials as ga_credentials  # type: ignore
from google.oauth2 import service_account  # type: ignore
from google.cloud.orchestration.airflow.service_v1beta1.types import environments
from google.longrunning import operations_pb2  # type: ignore

        [environments.ListEnvironmentsRequest],
        Union[
            environments.ListEnvironmentsResponse,
            Awaitable[environments.ListEnvironmentsResponse],
        ],
    ]:
        raise NotImplementedError()

    @property
    def update_environment(
        self,
    ) -> Callable[
        [environments.UpdateEnvironmentRequest],
        Union[operations_pb2.Operation, Awaitable[operations_pb2.Operation]],
    ]:
        raise NotImplementedError()

    @property
    def delete_environment(
        self,
    ) -> Callable[
        [environments.DeleteEnvironmentRequest],
        Union[operations_pb2.Operation, Awaitable[operations_pb2.Operation]],
    ]:
        raise NotImplementedError()

    @property
    def restart_web_server(
        self,
    ) -> Callable[

        [environments.RestartWebServerRequest],