diff --git a/sdk/go/astronomer/getApiTokens.go b/sdk/go/astronomer/getApiTokens.go index 6d20a46..3f2a26b 100644 --- a/sdk/go/astronomer/getApiTokens.go +++ b/sdk/go/astronomer/getApiTokens.go @@ -27,7 +27,7 @@ import ( // // func main() { // pulumi.Run(func(ctx *pulumi.Context) error { -// exampleApiTokens, err := astronomer.GetApiTokens(ctx, nil, nil) +// exampleApiTokens, err := astronomer.GetApiTokens(ctx, &astronomer.GetApiTokensArgs{}, nil) // if err != nil { // return err // } diff --git a/sdk/go/astronomer/getClusters.go b/sdk/go/astronomer/getClusters.go index 6c43887..11eaa52 100644 --- a/sdk/go/astronomer/getClusters.go +++ b/sdk/go/astronomer/getClusters.go @@ -27,7 +27,7 @@ import ( // // func main() { // pulumi.Run(func(ctx *pulumi.Context) error { -// exampleClusters, err := astronomer.GetClusters(ctx, nil, nil) +// exampleClusters, err := astronomer.GetClusters(ctx, &astronomer.GetClustersArgs{}, nil) // if err != nil { // return err // } diff --git a/sdk/go/astronomer/getDeploymentOptions.go b/sdk/go/astronomer/getDeploymentOptions.go index 8dc9686..0670aeb 100644 --- a/sdk/go/astronomer/getDeploymentOptions.go +++ b/sdk/go/astronomer/getDeploymentOptions.go @@ -27,7 +27,7 @@ import ( // // func main() { // pulumi.Run(func(ctx *pulumi.Context) error { -// exampleDeploymentOptions, err := astronomer.GetDeploymentOptions(ctx, nil, nil) +// exampleDeploymentOptions, err := astronomer.GetDeploymentOptions(ctx, &astronomer.GetDeploymentOptionsArgs{}, nil) // if err != nil { // return err // } diff --git a/sdk/go/astronomer/getDeployments.go b/sdk/go/astronomer/getDeployments.go index 5364acd..54e787d 100644 --- a/sdk/go/astronomer/getDeployments.go +++ b/sdk/go/astronomer/getDeployments.go @@ -27,7 +27,7 @@ import ( // // func main() { // pulumi.Run(func(ctx *pulumi.Context) error { -// exampleDeployments, err := astronomer.GetDeployments(ctx, nil, nil) +// exampleDeployments, err := astronomer.GetDeployments(ctx, &astronomer.GetDeploymentsArgs{}, nil) // if err != nil { // return err // } diff --git a/sdk/go/astronomer/getOrganization.go b/sdk/go/astronomer/getOrganization.go index fa5f04d..2c53350 100644 --- a/sdk/go/astronomer/getOrganization.go +++ b/sdk/go/astronomer/getOrganization.go @@ -27,7 +27,7 @@ import ( // // func main() { // pulumi.Run(func(ctx *pulumi.Context) error { -// exampleOrganization, err := astronomer.GetOrganization(ctx, nil, nil) +// exampleOrganization, err := astronomer.GetOrganization(ctx, map[string]interface{}{}, nil) // if err != nil { // return err // } diff --git a/sdk/go/astronomer/getTeams.go b/sdk/go/astronomer/getTeams.go index b1632e0..afbe74f 100644 --- a/sdk/go/astronomer/getTeams.go +++ b/sdk/go/astronomer/getTeams.go @@ -27,7 +27,7 @@ import ( // // func main() { // pulumi.Run(func(ctx *pulumi.Context) error { -// exampleTeamsTeams, err := astronomer.GetTeams(ctx, nil, nil) +// exampleTeamsTeams, err := astronomer.GetTeams(ctx, &astronomer.GetTeamsArgs{}, nil) // if err != nil { // return err // } diff --git a/sdk/go/astronomer/getUsers.go b/sdk/go/astronomer/getUsers.go index 12d4f60..2838714 100644 --- a/sdk/go/astronomer/getUsers.go +++ b/sdk/go/astronomer/getUsers.go @@ -27,7 +27,7 @@ import ( // // func main() { // pulumi.Run(func(ctx *pulumi.Context) error { -// exampleUsersUsers, err := astronomer.GetUsers(ctx, nil, nil) +// exampleUsersUsers, err := astronomer.GetUsers(ctx, &astronomer.GetUsersArgs{}, nil) // if err != nil { // return err // } diff --git a/sdk/go/astronomer/getWorkspaces.go b/sdk/go/astronomer/getWorkspaces.go index 613b42d..7c95405 100644 --- a/sdk/go/astronomer/getWorkspaces.go +++ b/sdk/go/astronomer/getWorkspaces.go @@ -27,7 +27,7 @@ import ( // // func main() { // pulumi.Run(func(ctx *pulumi.Context) error { -// exampleWorkspacesWorkspaces, err := astronomer.GetWorkspaces(ctx, nil, nil) +// exampleWorkspacesWorkspaces, err := astronomer.GetWorkspaces(ctx, &astronomer.GetWorkspacesArgs{}, nil) // if err != nil { // return err // } diff --git a/sdk/python/pulumi_astronomer/_inputs.py b/sdk/python/pulumi_astronomer/_inputs.py index 677e002..e1c2448 100644 --- a/sdk/python/pulumi_astronomer/_inputs.py +++ b/sdk/python/pulumi_astronomer/_inputs.py @@ -4,44 +4,92 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities __all__ = [ 'ApiTokenCreatedByArgs', + 'ApiTokenCreatedByArgsDict', 'ApiTokenRoleArgs', + 'ApiTokenRoleArgsDict', 'ApiTokenUpdatedByArgs', + 'ApiTokenUpdatedByArgsDict', 'ClusterHealthStatusArgs', + 'ClusterHealthStatusArgsDict', 'ClusterHealthStatusDetailArgs', + 'ClusterHealthStatusDetailArgsDict', 'ClusterMetadataArgs', + 'ClusterMetadataArgsDict', 'ClusterNodePoolArgs', + 'ClusterNodePoolArgsDict', 'ClusterTimeoutsArgs', + 'ClusterTimeoutsArgsDict', 'DeploymentCreatedByArgs', + 'DeploymentCreatedByArgsDict', 'DeploymentEnvironmentVariableArgs', + 'DeploymentEnvironmentVariableArgsDict', 'DeploymentScalingSpecArgs', + 'DeploymentScalingSpecArgsDict', 'DeploymentScalingSpecHibernationSpecArgs', + 'DeploymentScalingSpecHibernationSpecArgsDict', 'DeploymentScalingSpecHibernationSpecOverrideArgs', + 'DeploymentScalingSpecHibernationSpecOverrideArgsDict', 'DeploymentScalingSpecHibernationSpecScheduleArgs', + 'DeploymentScalingSpecHibernationSpecScheduleArgsDict', 'DeploymentScalingStatusArgs', + 'DeploymentScalingStatusArgsDict', 'DeploymentScalingStatusHibernationStatusArgs', + 'DeploymentScalingStatusHibernationStatusArgsDict', 'DeploymentUpdatedByArgs', + 'DeploymentUpdatedByArgsDict', 'DeploymentWorkerQueueArgs', + 'DeploymentWorkerQueueArgsDict', 'TeamCreatedByArgs', + 'TeamCreatedByArgsDict', 'TeamDeploymentRoleArgs', + 'TeamDeploymentRoleArgsDict', 'TeamRolesDeploymentRoleArgs', + 'TeamRolesDeploymentRoleArgsDict', 'TeamRolesWorkspaceRoleArgs', + 'TeamRolesWorkspaceRoleArgsDict', 'TeamUpdatedByArgs', + 'TeamUpdatedByArgsDict', 'TeamWorkspaceRoleArgs', + 'TeamWorkspaceRoleArgsDict', 'UserInviteInviteeArgs', + 'UserInviteInviteeArgsDict', 'UserInviteInviterArgs', + 'UserInviteInviterArgsDict', 'UserRolesDeploymentRoleArgs', + 'UserRolesDeploymentRoleArgsDict', 'UserRolesWorkspaceRoleArgs', + 'UserRolesWorkspaceRoleArgsDict', 'WorkspaceCreatedByArgs', + 'WorkspaceCreatedByArgsDict', 'WorkspaceUpdatedByArgs', + 'WorkspaceUpdatedByArgsDict', ] +MYPY = False + +if not MYPY: + class ApiTokenCreatedByArgsDict(TypedDict): + api_token_name: NotRequired[pulumi.Input[str]] + avatar_url: NotRequired[pulumi.Input[str]] + full_name: NotRequired[pulumi.Input[str]] + id: NotRequired[pulumi.Input[str]] + subject_type: NotRequired[pulumi.Input[str]] + username: NotRequired[pulumi.Input[str]] +elif False: + ApiTokenCreatedByArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class ApiTokenCreatedByArgs: def __init__(__self__, *, @@ -119,6 +167,23 @@ def username(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "username", value) +if not MYPY: + class ApiTokenRoleArgsDict(TypedDict): + entity_id: pulumi.Input[str] + """ + The ID of the entity to assign the role to + """ + entity_type: pulumi.Input[str] + """ + The type of entity to assign the role to + """ + role: pulumi.Input[str] + """ + The role to assign to the entity + """ +elif False: + ApiTokenRoleArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class ApiTokenRoleArgs: def __init__(__self__, *, @@ -171,6 +236,17 @@ def role(self, value: pulumi.Input[str]): pulumi.set(self, "role", value) +if not MYPY: + class ApiTokenUpdatedByArgsDict(TypedDict): + api_token_name: NotRequired[pulumi.Input[str]] + avatar_url: NotRequired[pulumi.Input[str]] + full_name: NotRequired[pulumi.Input[str]] + id: NotRequired[pulumi.Input[str]] + subject_type: NotRequired[pulumi.Input[str]] + username: NotRequired[pulumi.Input[str]] +elif False: + ApiTokenUpdatedByArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class ApiTokenUpdatedByArgs: def __init__(__self__, *, @@ -248,6 +324,19 @@ def username(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "username", value) +if not MYPY: + class ClusterHealthStatusArgsDict(TypedDict): + details: NotRequired[pulumi.Input[Sequence[pulumi.Input['ClusterHealthStatusDetailArgsDict']]]] + """ + Cluster health status details + """ + value: NotRequired[pulumi.Input[str]] + """ + Cluster health status value + """ +elif False: + ClusterHealthStatusArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class ClusterHealthStatusArgs: def __init__(__self__, *, @@ -287,6 +376,23 @@ def value(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "value", value) +if not MYPY: + class ClusterHealthStatusDetailArgsDict(TypedDict): + code: NotRequired[pulumi.Input[str]] + """ + Cluster health status detail code + """ + description: NotRequired[pulumi.Input[str]] + """ + Cluster health status detail description + """ + severity: NotRequired[pulumi.Input[str]] + """ + Cluster health status detail severity + """ +elif False: + ClusterHealthStatusDetailArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class ClusterHealthStatusDetailArgs: def __init__(__self__, *, @@ -342,6 +448,23 @@ def severity(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "severity", value) +if not MYPY: + class ClusterMetadataArgsDict(TypedDict): + external_ips: NotRequired[pulumi.Input[Sequence[pulumi.Input[str]]]] + """ + Cluster external IPs + """ + kube_dns_ip: NotRequired[pulumi.Input[str]] + """ + Cluster kube DNS IP + """ + oidc_issuer_url: NotRequired[pulumi.Input[str]] + """ + Cluster OIDC issuer URL + """ +elif False: + ClusterMetadataArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class ClusterMetadataArgs: def __init__(__self__, *, @@ -397,6 +520,51 @@ def oidc_issuer_url(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "oidc_issuer_url", value) +if not MYPY: + class ClusterNodePoolArgsDict(TypedDict): + cloud_provider: NotRequired[pulumi.Input[str]] + """ + Node pool cloud provider + """ + cluster_id: NotRequired[pulumi.Input[str]] + """ + Node pool cluster identifier + """ + created_at: NotRequired[pulumi.Input[str]] + """ + Node pool creation timestamp + """ + id: NotRequired[pulumi.Input[str]] + """ + Node pool identifier + """ + is_default: NotRequired[pulumi.Input[bool]] + """ + Whether the node pool is the default node pool of the cluster + """ + max_node_count: NotRequired[pulumi.Input[int]] + """ + Node pool maximum node count + """ + name: NotRequired[pulumi.Input[str]] + """ + Node pool name + """ + node_instance_type: NotRequired[pulumi.Input[str]] + """ + Node pool node instance type + """ + supported_astro_machines: NotRequired[pulumi.Input[Sequence[pulumi.Input[str]]]] + """ + Node pool supported Astro machines + """ + updated_at: NotRequired[pulumi.Input[str]] + """ + Node pool last updated timestamp + """ +elif False: + ClusterNodePoolArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class ClusterNodePoolArgs: def __init__(__self__, *, @@ -564,6 +732,23 @@ def updated_at(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "updated_at", value) +if not MYPY: + class ClusterTimeoutsArgsDict(TypedDict): + create: NotRequired[pulumi.Input[str]] + """ + A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). + """ + delete: NotRequired[pulumi.Input[str]] + """ + A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs. + """ + update: NotRequired[pulumi.Input[str]] + """ + A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). + """ +elif False: + ClusterTimeoutsArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class ClusterTimeoutsArgs: def __init__(__self__, *, @@ -619,6 +804,17 @@ def update(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "update", value) +if not MYPY: + class DeploymentCreatedByArgsDict(TypedDict): + api_token_name: NotRequired[pulumi.Input[str]] + avatar_url: NotRequired[pulumi.Input[str]] + full_name: NotRequired[pulumi.Input[str]] + id: NotRequired[pulumi.Input[str]] + subject_type: NotRequired[pulumi.Input[str]] + username: NotRequired[pulumi.Input[str]] +elif False: + DeploymentCreatedByArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class DeploymentCreatedByArgs: def __init__(__self__, *, @@ -696,6 +892,27 @@ def username(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "username", value) +if not MYPY: + class DeploymentEnvironmentVariableArgsDict(TypedDict): + is_secret: pulumi.Input[bool] + """ + Whether Environment variable is a secret + """ + key: pulumi.Input[str] + """ + Environment variable key + """ + updated_at: NotRequired[pulumi.Input[str]] + """ + Environment variable last updated timestamp + """ + value: NotRequired[pulumi.Input[str]] + """ + Environment variable value + """ +elif False: + DeploymentEnvironmentVariableArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class DeploymentEnvironmentVariableArgs: def __init__(__self__, *, @@ -765,6 +982,15 @@ def value(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "value", value) +if not MYPY: + class DeploymentScalingSpecArgsDict(TypedDict): + hibernation_spec: pulumi.Input['DeploymentScalingSpecHibernationSpecArgsDict'] + """ + Hibernation configuration for the deployment. The deployment will hibernate according to the schedules defined in this configuration. To remove the hibernation configuration, set scaling*spec to null. + """ +elif False: + DeploymentScalingSpecArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class DeploymentScalingSpecArgs: def __init__(__self__, *, @@ -787,6 +1013,19 @@ def hibernation_spec(self, value: pulumi.Input['DeploymentScalingSpecHibernation pulumi.set(self, "hibernation_spec", value) +if not MYPY: + class DeploymentScalingSpecHibernationSpecArgsDict(TypedDict): + override: NotRequired[pulumi.Input['DeploymentScalingSpecHibernationSpecOverrideArgsDict']] + """ + Hibernation override configuration. Set to null to remove the override. + """ + schedules: NotRequired[pulumi.Input[Sequence[pulumi.Input['DeploymentScalingSpecHibernationSpecScheduleArgsDict']]]] + """ + List of hibernation schedules. Set to null to remove all schedules. + """ +elif False: + DeploymentScalingSpecHibernationSpecArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class DeploymentScalingSpecHibernationSpecArgs: def __init__(__self__, *, @@ -826,6 +1065,14 @@ def schedules(self, value: Optional[pulumi.Input[Sequence[pulumi.Input['Deployme pulumi.set(self, "schedules", value) +if not MYPY: + class DeploymentScalingSpecHibernationSpecOverrideArgsDict(TypedDict): + is_hibernating: pulumi.Input[bool] + is_active: NotRequired[pulumi.Input[bool]] + override_until: NotRequired[pulumi.Input[str]] +elif False: + DeploymentScalingSpecHibernationSpecOverrideArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class DeploymentScalingSpecHibernationSpecOverrideArgs: def __init__(__self__, *, @@ -866,6 +1113,15 @@ def override_until(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "override_until", value) +if not MYPY: + class DeploymentScalingSpecHibernationSpecScheduleArgsDict(TypedDict): + hibernate_at_cron: pulumi.Input[str] + is_enabled: pulumi.Input[bool] + wake_at_cron: pulumi.Input[str] + description: NotRequired[pulumi.Input[str]] +elif False: + DeploymentScalingSpecHibernationSpecScheduleArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class DeploymentScalingSpecHibernationSpecScheduleArgs: def __init__(__self__, *, @@ -916,6 +1172,12 @@ def description(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "description", value) +if not MYPY: + class DeploymentScalingStatusArgsDict(TypedDict): + hibernation_status: NotRequired[pulumi.Input['DeploymentScalingStatusHibernationStatusArgsDict']] +elif False: + DeploymentScalingStatusArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class DeploymentScalingStatusArgs: def __init__(__self__, *, @@ -933,6 +1195,15 @@ def hibernation_status(self, value: Optional[pulumi.Input['DeploymentScalingStat pulumi.set(self, "hibernation_status", value) +if not MYPY: + class DeploymentScalingStatusHibernationStatusArgsDict(TypedDict): + is_hibernating: NotRequired[pulumi.Input[bool]] + next_event_at: NotRequired[pulumi.Input[str]] + next_event_type: NotRequired[pulumi.Input[str]] + reason: NotRequired[pulumi.Input[str]] +elif False: + DeploymentScalingStatusHibernationStatusArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class DeploymentScalingStatusHibernationStatusArgs: def __init__(__self__, *, @@ -986,6 +1257,17 @@ def reason(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "reason", value) +if not MYPY: + class DeploymentUpdatedByArgsDict(TypedDict): + api_token_name: NotRequired[pulumi.Input[str]] + avatar_url: NotRequired[pulumi.Input[str]] + full_name: NotRequired[pulumi.Input[str]] + id: NotRequired[pulumi.Input[str]] + subject_type: NotRequired[pulumi.Input[str]] + username: NotRequired[pulumi.Input[str]] +elif False: + DeploymentUpdatedByArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class DeploymentUpdatedByArgs: def __init__(__self__, *, @@ -1063,6 +1345,47 @@ def username(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "username", value) +if not MYPY: + class DeploymentWorkerQueueArgsDict(TypedDict): + is_default: pulumi.Input[bool] + """ + Worker queue default + """ + max_worker_count: pulumi.Input[int] + """ + Worker queue max worker count + """ + min_worker_count: pulumi.Input[int] + """ + Worker queue min worker count + """ + name: pulumi.Input[str] + """ + Worker queue name + """ + worker_concurrency: pulumi.Input[int] + """ + Worker queue worker concurrency + """ + astro_machine: NotRequired[pulumi.Input[str]] + """ + Worker queue Astro machine value - required for 'STANDARD' and 'DEDICATED' deployments + """ + node_pool_id: NotRequired[pulumi.Input[str]] + """ + Worker queue Node pool identifier - required for 'HYBRID' deployments + """ + pod_cpu: NotRequired[pulumi.Input[str]] + """ + Worker queue pod CPU + """ + pod_memory: NotRequired[pulumi.Input[str]] + """ + Worker queue pod memory + """ +elif False: + DeploymentWorkerQueueArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class DeploymentWorkerQueueArgs: def __init__(__self__, *, @@ -1209,6 +1532,17 @@ def pod_memory(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "pod_memory", value) +if not MYPY: + class TeamCreatedByArgsDict(TypedDict): + api_token_name: NotRequired[pulumi.Input[str]] + avatar_url: NotRequired[pulumi.Input[str]] + full_name: NotRequired[pulumi.Input[str]] + id: NotRequired[pulumi.Input[str]] + subject_type: NotRequired[pulumi.Input[str]] + username: NotRequired[pulumi.Input[str]] +elif False: + TeamCreatedByArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class TeamCreatedByArgs: def __init__(__self__, *, @@ -1286,6 +1620,19 @@ def username(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "username", value) +if not MYPY: + class TeamDeploymentRoleArgsDict(TypedDict): + deployment_id: pulumi.Input[str] + """ + The ID of the deployment to assign the role to + """ + role: pulumi.Input[str] + """ + The role to assign to the deployment + """ +elif False: + TeamDeploymentRoleArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class TeamDeploymentRoleArgs: def __init__(__self__, *, @@ -1323,6 +1670,19 @@ def role(self, value: pulumi.Input[str]): pulumi.set(self, "role", value) +if not MYPY: + class TeamRolesDeploymentRoleArgsDict(TypedDict): + deployment_id: pulumi.Input[str] + """ + The ID of the deployment to assign the role to + """ + role: pulumi.Input[str] + """ + The role to assign to the deployment + """ +elif False: + TeamRolesDeploymentRoleArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class TeamRolesDeploymentRoleArgs: def __init__(__self__, *, @@ -1360,6 +1720,19 @@ def role(self, value: pulumi.Input[str]): pulumi.set(self, "role", value) +if not MYPY: + class TeamRolesWorkspaceRoleArgsDict(TypedDict): + role: pulumi.Input[str] + """ + The role to assign to the workspace + """ + workspace_id: pulumi.Input[str] + """ + The ID of the workspace to assign the role to + """ +elif False: + TeamRolesWorkspaceRoleArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class TeamRolesWorkspaceRoleArgs: def __init__(__self__, *, @@ -1397,6 +1770,17 @@ def workspace_id(self, value: pulumi.Input[str]): pulumi.set(self, "workspace_id", value) +if not MYPY: + class TeamUpdatedByArgsDict(TypedDict): + api_token_name: NotRequired[pulumi.Input[str]] + avatar_url: NotRequired[pulumi.Input[str]] + full_name: NotRequired[pulumi.Input[str]] + id: NotRequired[pulumi.Input[str]] + subject_type: NotRequired[pulumi.Input[str]] + username: NotRequired[pulumi.Input[str]] +elif False: + TeamUpdatedByArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class TeamUpdatedByArgs: def __init__(__self__, *, @@ -1474,6 +1858,19 @@ def username(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "username", value) +if not MYPY: + class TeamWorkspaceRoleArgsDict(TypedDict): + role: pulumi.Input[str] + """ + The role to assign to the workspace + """ + workspace_id: pulumi.Input[str] + """ + The ID of the workspace to assign the role to + """ +elif False: + TeamWorkspaceRoleArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class TeamWorkspaceRoleArgs: def __init__(__self__, *, @@ -1511,6 +1908,17 @@ def workspace_id(self, value: pulumi.Input[str]): pulumi.set(self, "workspace_id", value) +if not MYPY: + class UserInviteInviteeArgsDict(TypedDict): + api_token_name: NotRequired[pulumi.Input[str]] + avatar_url: NotRequired[pulumi.Input[str]] + full_name: NotRequired[pulumi.Input[str]] + id: NotRequired[pulumi.Input[str]] + subject_type: NotRequired[pulumi.Input[str]] + username: NotRequired[pulumi.Input[str]] +elif False: + UserInviteInviteeArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class UserInviteInviteeArgs: def __init__(__self__, *, @@ -1588,6 +1996,17 @@ def username(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "username", value) +if not MYPY: + class UserInviteInviterArgsDict(TypedDict): + api_token_name: NotRequired[pulumi.Input[str]] + avatar_url: NotRequired[pulumi.Input[str]] + full_name: NotRequired[pulumi.Input[str]] + id: NotRequired[pulumi.Input[str]] + subject_type: NotRequired[pulumi.Input[str]] + username: NotRequired[pulumi.Input[str]] +elif False: + UserInviteInviterArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class UserInviteInviterArgs: def __init__(__self__, *, @@ -1665,6 +2084,19 @@ def username(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "username", value) +if not MYPY: + class UserRolesDeploymentRoleArgsDict(TypedDict): + deployment_id: pulumi.Input[str] + """ + The ID of the deployment to assign the role to + """ + role: pulumi.Input[str] + """ + The role to assign to the deployment + """ +elif False: + UserRolesDeploymentRoleArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class UserRolesDeploymentRoleArgs: def __init__(__self__, *, @@ -1702,6 +2134,19 @@ def role(self, value: pulumi.Input[str]): pulumi.set(self, "role", value) +if not MYPY: + class UserRolesWorkspaceRoleArgsDict(TypedDict): + role: pulumi.Input[str] + """ + The role to assign to the workspace + """ + workspace_id: pulumi.Input[str] + """ + The ID of the workspace to assign the role to + """ +elif False: + UserRolesWorkspaceRoleArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class UserRolesWorkspaceRoleArgs: def __init__(__self__, *, @@ -1739,6 +2184,17 @@ def workspace_id(self, value: pulumi.Input[str]): pulumi.set(self, "workspace_id", value) +if not MYPY: + class WorkspaceCreatedByArgsDict(TypedDict): + api_token_name: NotRequired[pulumi.Input[str]] + avatar_url: NotRequired[pulumi.Input[str]] + full_name: NotRequired[pulumi.Input[str]] + id: NotRequired[pulumi.Input[str]] + subject_type: NotRequired[pulumi.Input[str]] + username: NotRequired[pulumi.Input[str]] +elif False: + WorkspaceCreatedByArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class WorkspaceCreatedByArgs: def __init__(__self__, *, @@ -1816,6 +2272,17 @@ def username(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "username", value) +if not MYPY: + class WorkspaceUpdatedByArgsDict(TypedDict): + api_token_name: NotRequired[pulumi.Input[str]] + avatar_url: NotRequired[pulumi.Input[str]] + full_name: NotRequired[pulumi.Input[str]] + id: NotRequired[pulumi.Input[str]] + subject_type: NotRequired[pulumi.Input[str]] + username: NotRequired[pulumi.Input[str]] +elif False: + WorkspaceUpdatedByArgsDict: TypeAlias = Mapping[str, Any] + @pulumi.input_type class WorkspaceUpdatedByArgs: def __init__(__self__, *, diff --git a/sdk/python/pulumi_astronomer/_utilities.py b/sdk/python/pulumi_astronomer/_utilities.py index d676b95..cb05df8 100644 --- a/sdk/python/pulumi_astronomer/_utilities.py +++ b/sdk/python/pulumi_astronomer/_utilities.py @@ -264,7 +264,7 @@ def call_plain( output = pulumi.runtime.call(tok, props, res, typ) # Ingoring deps silently. They are typically non-empty, r.f() calls include r as a dependency. - result, known, secret, _ = _sync_await(asyncio.ensure_future(_await_output(output))) + result, known, secret, _ = _sync_await(asyncio.create_task(_await_output(output))) problem = None if not known: diff --git a/sdk/python/pulumi_astronomer/api_token.py b/sdk/python/pulumi_astronomer/api_token.py index cd3f9e8..4d0a9d4 100644 --- a/sdk/python/pulumi_astronomer/api_token.py +++ b/sdk/python/pulumi_astronomer/api_token.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs from ._inputs import * diff --git a/sdk/python/pulumi_astronomer/cluster.py b/sdk/python/pulumi_astronomer/cluster.py index 606bdab..eddfd2d 100644 --- a/sdk/python/pulumi_astronomer/cluster.py +++ b/sdk/python/pulumi_astronomer/cluster.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs from ._inputs import * diff --git a/sdk/python/pulumi_astronomer/config/__init__.pyi b/sdk/python/pulumi_astronomer/config/__init__.pyi index 9903182..c87d366 100644 --- a/sdk/python/pulumi_astronomer/config/__init__.pyi +++ b/sdk/python/pulumi_astronomer/config/__init__.pyi @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from .. import _utilities host: Optional[str] diff --git a/sdk/python/pulumi_astronomer/config/vars.py b/sdk/python/pulumi_astronomer/config/vars.py index 2ef9609..5da1c11 100644 --- a/sdk/python/pulumi_astronomer/config/vars.py +++ b/sdk/python/pulumi_astronomer/config/vars.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from .. import _utilities import types diff --git a/sdk/python/pulumi_astronomer/deployment.py b/sdk/python/pulumi_astronomer/deployment.py index 95ee8d5..f8328f6 100644 --- a/sdk/python/pulumi_astronomer/deployment.py +++ b/sdk/python/pulumi_astronomer/deployment.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs from ._inputs import * diff --git a/sdk/python/pulumi_astronomer/get_api_token.py b/sdk/python/pulumi_astronomer/get_api_token.py index 8447bd3..af75abd 100644 --- a/sdk/python/pulumi_astronomer/get_api_token.py +++ b/sdk/python/pulumi_astronomer/get_api_token.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -239,9 +244,6 @@ def get_api_token(id: Optional[str] = None, type=pulumi.get(__ret__, 'type'), updated_at=pulumi.get(__ret__, 'updated_at'), updated_by=pulumi.get(__ret__, 'updated_by')) - - -@_utilities.lift_output_func(get_api_token) def get_api_token_output(id: Optional[pulumi.Input[str]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetApiTokenResult]: """ @@ -260,4 +262,22 @@ def get_api_token_output(id: Optional[pulumi.Input[str]] = None, :param str id: API Token identifier """ - ... + __args__ = dict() + __args__['id'] = id + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getApiToken:getApiToken', __args__, opts=opts, typ=GetApiTokenResult) + return __ret__.apply(lambda __response__: GetApiTokenResult( + created_at=pulumi.get(__response__, 'created_at'), + created_by=pulumi.get(__response__, 'created_by'), + description=pulumi.get(__response__, 'description'), + end_at=pulumi.get(__response__, 'end_at'), + expiry_period_in_days=pulumi.get(__response__, 'expiry_period_in_days'), + id=pulumi.get(__response__, 'id'), + last_used_at=pulumi.get(__response__, 'last_used_at'), + name=pulumi.get(__response__, 'name'), + roles=pulumi.get(__response__, 'roles'), + short_token=pulumi.get(__response__, 'short_token'), + start_at=pulumi.get(__response__, 'start_at'), + type=pulumi.get(__response__, 'type'), + updated_at=pulumi.get(__response__, 'updated_at'), + updated_by=pulumi.get(__response__, 'updated_by'))) diff --git a/sdk/python/pulumi_astronomer/get_api_tokens.py b/sdk/python/pulumi_astronomer/get_api_tokens.py index 539d7d9..cfffee9 100644 --- a/sdk/python/pulumi_astronomer/get_api_tokens.py +++ b/sdk/python/pulumi_astronomer/get_api_tokens.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -114,9 +119,6 @@ def get_api_tokens(deployment_id: Optional[str] = None, id=pulumi.get(__ret__, 'id'), include_only_organization_tokens=pulumi.get(__ret__, 'include_only_organization_tokens'), workspace_id=pulumi.get(__ret__, 'workspace_id')) - - -@_utilities.lift_output_func(get_api_tokens) def get_api_tokens_output(deployment_id: Optional[pulumi.Input[Optional[str]]] = None, include_only_organization_tokens: Optional[pulumi.Input[Optional[bool]]] = None, workspace_id: Optional[pulumi.Input[Optional[str]]] = None, @@ -137,4 +139,15 @@ def get_api_tokens_output(deployment_id: Optional[pulumi.Input[Optional[str]]] = pulumi.export("apiTokens", example_api_tokens) ``` """ - ... + __args__ = dict() + __args__['deploymentId'] = deployment_id + __args__['includeOnlyOrganizationTokens'] = include_only_organization_tokens + __args__['workspaceId'] = workspace_id + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getApiTokens:getApiTokens', __args__, opts=opts, typ=GetApiTokensResult) + return __ret__.apply(lambda __response__: GetApiTokensResult( + api_tokens=pulumi.get(__response__, 'api_tokens'), + deployment_id=pulumi.get(__response__, 'deployment_id'), + id=pulumi.get(__response__, 'id'), + include_only_organization_tokens=pulumi.get(__response__, 'include_only_organization_tokens'), + workspace_id=pulumi.get(__response__, 'workspace_id'))) diff --git a/sdk/python/pulumi_astronomer/get_cluster.py b/sdk/python/pulumi_astronomer/get_cluster.py index 25937d9..d2b3ffd 100644 --- a/sdk/python/pulumi_astronomer/get_cluster.py +++ b/sdk/python/pulumi_astronomer/get_cluster.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -330,9 +335,6 @@ def get_cluster(id: Optional[str] = None, updated_at=pulumi.get(__ret__, 'updated_at'), vpc_subnet_range=pulumi.get(__ret__, 'vpc_subnet_range'), workspace_ids=pulumi.get(__ret__, 'workspace_ids')) - - -@_utilities.lift_output_func(get_cluster) def get_cluster_output(id: Optional[pulumi.Input[str]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetClusterResult]: """ @@ -351,4 +353,29 @@ def get_cluster_output(id: Optional[pulumi.Input[str]] = None, :param str id: Cluster identifier """ - ... + __args__ = dict() + __args__['id'] = id + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getCluster:getCluster', __args__, opts=opts, typ=GetClusterResult) + return __ret__.apply(lambda __response__: GetClusterResult( + cloud_provider=pulumi.get(__response__, 'cloud_provider'), + created_at=pulumi.get(__response__, 'created_at'), + db_instance_type=pulumi.get(__response__, 'db_instance_type'), + health_status=pulumi.get(__response__, 'health_status'), + id=pulumi.get(__response__, 'id'), + is_limited=pulumi.get(__response__, 'is_limited'), + metadata=pulumi.get(__response__, 'metadata'), + name=pulumi.get(__response__, 'name'), + node_pools=pulumi.get(__response__, 'node_pools'), + pod_subnet_range=pulumi.get(__response__, 'pod_subnet_range'), + provider_account=pulumi.get(__response__, 'provider_account'), + region=pulumi.get(__response__, 'region'), + service_peering_range=pulumi.get(__response__, 'service_peering_range'), + service_subnet_range=pulumi.get(__response__, 'service_subnet_range'), + status=pulumi.get(__response__, 'status'), + tags=pulumi.get(__response__, 'tags'), + tenant_id=pulumi.get(__response__, 'tenant_id'), + type=pulumi.get(__response__, 'type'), + updated_at=pulumi.get(__response__, 'updated_at'), + vpc_subnet_range=pulumi.get(__response__, 'vpc_subnet_range'), + workspace_ids=pulumi.get(__response__, 'workspace_ids'))) diff --git a/sdk/python/pulumi_astronomer/get_cluster_options.py b/sdk/python/pulumi_astronomer/get_cluster_options.py index efd1186..7cfdd3a 100644 --- a/sdk/python/pulumi_astronomer/get_cluster_options.py +++ b/sdk/python/pulumi_astronomer/get_cluster_options.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -101,9 +106,6 @@ def get_cluster_options(cloud_provider: Optional[str] = None, cluster_options=pulumi.get(__ret__, 'cluster_options'), id=pulumi.get(__ret__, 'id'), type=pulumi.get(__ret__, 'type')) - - -@_utilities.lift_output_func(get_cluster_options) def get_cluster_options_output(cloud_provider: Optional[pulumi.Input[Optional[str]]] = None, type: Optional[pulumi.Input[str]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetClusterOptionsResult]: @@ -122,4 +124,13 @@ def get_cluster_options_output(cloud_provider: Optional[pulumi.Input[Optional[st pulumi.export("clusterOptions", example_cluster_options) ``` """ - ... + __args__ = dict() + __args__['cloudProvider'] = cloud_provider + __args__['type'] = type + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getClusterOptions:getClusterOptions', __args__, opts=opts, typ=GetClusterOptionsResult) + return __ret__.apply(lambda __response__: GetClusterOptionsResult( + cloud_provider=pulumi.get(__response__, 'cloud_provider'), + cluster_options=pulumi.get(__response__, 'cluster_options'), + id=pulumi.get(__response__, 'id'), + type=pulumi.get(__response__, 'type'))) diff --git a/sdk/python/pulumi_astronomer/get_clusters.py b/sdk/python/pulumi_astronomer/get_clusters.py index 7d8760f..25d6e81 100644 --- a/sdk/python/pulumi_astronomer/get_clusters.py +++ b/sdk/python/pulumi_astronomer/get_clusters.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -101,9 +106,6 @@ def get_clusters(cloud_provider: Optional[str] = None, clusters=pulumi.get(__ret__, 'clusters'), id=pulumi.get(__ret__, 'id'), names=pulumi.get(__ret__, 'names')) - - -@_utilities.lift_output_func(get_clusters) def get_clusters_output(cloud_provider: Optional[pulumi.Input[Optional[str]]] = None, names: Optional[pulumi.Input[Optional[Sequence[str]]]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetClustersResult]: @@ -122,4 +124,13 @@ def get_clusters_output(cloud_provider: Optional[pulumi.Input[Optional[str]]] = pulumi.export("clusters", example_clusters) ``` """ - ... + __args__ = dict() + __args__['cloudProvider'] = cloud_provider + __args__['names'] = names + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getClusters:getClusters', __args__, opts=opts, typ=GetClustersResult) + return __ret__.apply(lambda __response__: GetClustersResult( + cloud_provider=pulumi.get(__response__, 'cloud_provider'), + clusters=pulumi.get(__response__, 'clusters'), + id=pulumi.get(__response__, 'id'), + names=pulumi.get(__response__, 'names'))) diff --git a/sdk/python/pulumi_astronomer/get_deployment.py b/sdk/python/pulumi_astronomer/get_deployment.py index 91fe61a..c06cf26 100644 --- a/sdk/python/pulumi_astronomer/get_deployment.py +++ b/sdk/python/pulumi_astronomer/get_deployment.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -681,9 +686,6 @@ def get_deployment(id: Optional[str] = None, worker_queues=pulumi.get(__ret__, 'worker_queues'), workload_identity=pulumi.get(__ret__, 'workload_identity'), workspace_id=pulumi.get(__ret__, 'workspace_id')) - - -@_utilities.lift_output_func(get_deployment) def get_deployment_output(id: Optional[pulumi.Input[str]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetDeploymentResult]: """ @@ -702,4 +704,56 @@ def get_deployment_output(id: Optional[pulumi.Input[str]] = None, :param str id: Deployment identifier """ - ... + __args__ = dict() + __args__['id'] = id + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getDeployment:getDeployment', __args__, opts=opts, typ=GetDeploymentResult) + return __ret__.apply(lambda __response__: GetDeploymentResult( + airflow_version=pulumi.get(__response__, 'airflow_version'), + astro_runtime_version=pulumi.get(__response__, 'astro_runtime_version'), + cloud_provider=pulumi.get(__response__, 'cloud_provider'), + cluster_id=pulumi.get(__response__, 'cluster_id'), + contact_emails=pulumi.get(__response__, 'contact_emails'), + created_at=pulumi.get(__response__, 'created_at'), + created_by=pulumi.get(__response__, 'created_by'), + dag_tarball_version=pulumi.get(__response__, 'dag_tarball_version'), + default_task_pod_cpu=pulumi.get(__response__, 'default_task_pod_cpu'), + default_task_pod_memory=pulumi.get(__response__, 'default_task_pod_memory'), + description=pulumi.get(__response__, 'description'), + desired_dag_tarball_version=pulumi.get(__response__, 'desired_dag_tarball_version'), + environment_variables=pulumi.get(__response__, 'environment_variables'), + executor=pulumi.get(__response__, 'executor'), + external_ips=pulumi.get(__response__, 'external_ips'), + id=pulumi.get(__response__, 'id'), + image_repository=pulumi.get(__response__, 'image_repository'), + image_tag=pulumi.get(__response__, 'image_tag'), + image_version=pulumi.get(__response__, 'image_version'), + is_cicd_enforced=pulumi.get(__response__, 'is_cicd_enforced'), + is_dag_deploy_enabled=pulumi.get(__response__, 'is_dag_deploy_enabled'), + is_development_mode=pulumi.get(__response__, 'is_development_mode'), + is_high_availability=pulumi.get(__response__, 'is_high_availability'), + name=pulumi.get(__response__, 'name'), + namespace=pulumi.get(__response__, 'namespace'), + oidc_issuer_url=pulumi.get(__response__, 'oidc_issuer_url'), + region=pulumi.get(__response__, 'region'), + resource_quota_cpu=pulumi.get(__response__, 'resource_quota_cpu'), + resource_quota_memory=pulumi.get(__response__, 'resource_quota_memory'), + scaling_spec=pulumi.get(__response__, 'scaling_spec'), + scaling_status=pulumi.get(__response__, 'scaling_status'), + scheduler_au=pulumi.get(__response__, 'scheduler_au'), + scheduler_cpu=pulumi.get(__response__, 'scheduler_cpu'), + scheduler_memory=pulumi.get(__response__, 'scheduler_memory'), + scheduler_replicas=pulumi.get(__response__, 'scheduler_replicas'), + scheduler_size=pulumi.get(__response__, 'scheduler_size'), + status=pulumi.get(__response__, 'status'), + status_reason=pulumi.get(__response__, 'status_reason'), + task_pod_node_pool_id=pulumi.get(__response__, 'task_pod_node_pool_id'), + type=pulumi.get(__response__, 'type'), + updated_at=pulumi.get(__response__, 'updated_at'), + updated_by=pulumi.get(__response__, 'updated_by'), + webserver_airflow_api_url=pulumi.get(__response__, 'webserver_airflow_api_url'), + webserver_ingress_hostname=pulumi.get(__response__, 'webserver_ingress_hostname'), + webserver_url=pulumi.get(__response__, 'webserver_url'), + worker_queues=pulumi.get(__response__, 'worker_queues'), + workload_identity=pulumi.get(__response__, 'workload_identity'), + workspace_id=pulumi.get(__response__, 'workspace_id'))) diff --git a/sdk/python/pulumi_astronomer/get_deployment_options.py b/sdk/python/pulumi_astronomer/get_deployment_options.py index 0d0601e..96c0b9f 100644 --- a/sdk/python/pulumi_astronomer/get_deployment_options.py +++ b/sdk/python/pulumi_astronomer/get_deployment_options.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -226,9 +231,6 @@ def get_deployment_options(cloud_provider: Optional[str] = None, worker_machines=pulumi.get(__ret__, 'worker_machines'), worker_queues=pulumi.get(__ret__, 'worker_queues'), workload_identity_options=pulumi.get(__ret__, 'workload_identity_options')) - - -@_utilities.lift_output_func(get_deployment_options) def get_deployment_options_output(cloud_provider: Optional[pulumi.Input[Optional[str]]] = None, deployment_id: Optional[pulumi.Input[Optional[str]]] = None, deployment_type: Optional[pulumi.Input[Optional[str]]] = None, @@ -257,4 +259,23 @@ def get_deployment_options_output(cloud_provider: Optional[pulumi.Input[Optional :param str deployment_type: Deployment type :param str executor: Executor """ - ... + __args__ = dict() + __args__['cloudProvider'] = cloud_provider + __args__['deploymentId'] = deployment_id + __args__['deploymentType'] = deployment_type + __args__['executor'] = executor + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getDeploymentOptions:getDeploymentOptions', __args__, opts=opts, typ=GetDeploymentOptionsResult) + return __ret__.apply(lambda __response__: GetDeploymentOptionsResult( + cloud_provider=pulumi.get(__response__, 'cloud_provider'), + deployment_id=pulumi.get(__response__, 'deployment_id'), + deployment_type=pulumi.get(__response__, 'deployment_type'), + executor=pulumi.get(__response__, 'executor'), + executors=pulumi.get(__response__, 'executors'), + id=pulumi.get(__response__, 'id'), + resource_quotas=pulumi.get(__response__, 'resource_quotas'), + runtime_releases=pulumi.get(__response__, 'runtime_releases'), + scheduler_machines=pulumi.get(__response__, 'scheduler_machines'), + worker_machines=pulumi.get(__response__, 'worker_machines'), + worker_queues=pulumi.get(__response__, 'worker_queues'), + workload_identity_options=pulumi.get(__response__, 'workload_identity_options'))) diff --git a/sdk/python/pulumi_astronomer/get_deployments.py b/sdk/python/pulumi_astronomer/get_deployments.py index 9024ee3..a2184e2 100644 --- a/sdk/python/pulumi_astronomer/get_deployments.py +++ b/sdk/python/pulumi_astronomer/get_deployments.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -114,9 +119,6 @@ def get_deployments(deployment_ids: Optional[Sequence[str]] = None, id=pulumi.get(__ret__, 'id'), names=pulumi.get(__ret__, 'names'), workspace_ids=pulumi.get(__ret__, 'workspace_ids')) - - -@_utilities.lift_output_func(get_deployments) def get_deployments_output(deployment_ids: Optional[pulumi.Input[Optional[Sequence[str]]]] = None, names: Optional[pulumi.Input[Optional[Sequence[str]]]] = None, workspace_ids: Optional[pulumi.Input[Optional[Sequence[str]]]] = None, @@ -137,4 +139,15 @@ def get_deployments_output(deployment_ids: Optional[pulumi.Input[Optional[Sequen pulumi.export("deployments", example_deployments) ``` """ - ... + __args__ = dict() + __args__['deploymentIds'] = deployment_ids + __args__['names'] = names + __args__['workspaceIds'] = workspace_ids + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getDeployments:getDeployments', __args__, opts=opts, typ=GetDeploymentsResult) + return __ret__.apply(lambda __response__: GetDeploymentsResult( + deployment_ids=pulumi.get(__response__, 'deployment_ids'), + deployments=pulumi.get(__response__, 'deployments'), + id=pulumi.get(__response__, 'id'), + names=pulumi.get(__response__, 'names'), + workspace_ids=pulumi.get(__response__, 'workspace_ids'))) diff --git a/sdk/python/pulumi_astronomer/get_organization.py b/sdk/python/pulumi_astronomer/get_organization.py index 3a4df97..89b1cd6 100644 --- a/sdk/python/pulumi_astronomer/get_organization.py +++ b/sdk/python/pulumi_astronomer/get_organization.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -221,9 +226,6 @@ def get_organization(opts: Optional[pulumi.InvokeOptions] = None) -> AwaitableGe trial_expires_at=pulumi.get(__ret__, 'trial_expires_at'), updated_at=pulumi.get(__ret__, 'updated_at'), updated_by=pulumi.get(__ret__, 'updated_by')) - - -@_utilities.lift_output_func(get_organization) def get_organization_output(opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetOrganizationResult]: """ Organization data source @@ -238,4 +240,20 @@ def get_organization_output(opts: Optional[pulumi.InvokeOptions] = None) -> pulu pulumi.export("organization", example_organization) ``` """ - ... + __args__ = dict() + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getOrganization:getOrganization', __args__, opts=opts, typ=GetOrganizationResult) + return __ret__.apply(lambda __response__: GetOrganizationResult( + billing_email=pulumi.get(__response__, 'billing_email'), + created_at=pulumi.get(__response__, 'created_at'), + created_by=pulumi.get(__response__, 'created_by'), + id=pulumi.get(__response__, 'id'), + is_scim_enabled=pulumi.get(__response__, 'is_scim_enabled'), + name=pulumi.get(__response__, 'name'), + payment_method=pulumi.get(__response__, 'payment_method'), + product=pulumi.get(__response__, 'product'), + status=pulumi.get(__response__, 'status'), + support_plan=pulumi.get(__response__, 'support_plan'), + trial_expires_at=pulumi.get(__response__, 'trial_expires_at'), + updated_at=pulumi.get(__response__, 'updated_at'), + updated_by=pulumi.get(__response__, 'updated_by'))) diff --git a/sdk/python/pulumi_astronomer/get_team.py b/sdk/python/pulumi_astronomer/get_team.py index 8a663bd..4dfb4e8 100644 --- a/sdk/python/pulumi_astronomer/get_team.py +++ b/sdk/python/pulumi_astronomer/get_team.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -213,9 +218,6 @@ def get_team(id: Optional[str] = None, updated_at=pulumi.get(__ret__, 'updated_at'), updated_by=pulumi.get(__ret__, 'updated_by'), workspace_roles=pulumi.get(__ret__, 'workspace_roles')) - - -@_utilities.lift_output_func(get_team) def get_team_output(id: Optional[pulumi.Input[str]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetTeamResult]: """ @@ -234,4 +236,20 @@ def get_team_output(id: Optional[pulumi.Input[str]] = None, :param str id: Team ID """ - ... + __args__ = dict() + __args__['id'] = id + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getTeam:getTeam', __args__, opts=opts, typ=GetTeamResult) + return __ret__.apply(lambda __response__: GetTeamResult( + created_at=pulumi.get(__response__, 'created_at'), + created_by=pulumi.get(__response__, 'created_by'), + deployment_roles=pulumi.get(__response__, 'deployment_roles'), + description=pulumi.get(__response__, 'description'), + id=pulumi.get(__response__, 'id'), + is_idp_managed=pulumi.get(__response__, 'is_idp_managed'), + name=pulumi.get(__response__, 'name'), + organization_role=pulumi.get(__response__, 'organization_role'), + roles_count=pulumi.get(__response__, 'roles_count'), + updated_at=pulumi.get(__response__, 'updated_at'), + updated_by=pulumi.get(__response__, 'updated_by'), + workspace_roles=pulumi.get(__response__, 'workspace_roles'))) diff --git a/sdk/python/pulumi_astronomer/get_teams.py b/sdk/python/pulumi_astronomer/get_teams.py index 979b9b0..758f02a 100644 --- a/sdk/python/pulumi_astronomer/get_teams.py +++ b/sdk/python/pulumi_astronomer/get_teams.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -91,9 +96,6 @@ def get_teams(names: Optional[Sequence[str]] = None, id=pulumi.get(__ret__, 'id'), names=pulumi.get(__ret__, 'names'), teams=pulumi.get(__ret__, 'teams')) - - -@_utilities.lift_output_func(get_teams) def get_teams_output(names: Optional[pulumi.Input[Optional[Sequence[str]]]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetTeamsResult]: """ @@ -113,4 +115,11 @@ def get_teams_output(names: Optional[pulumi.Input[Optional[Sequence[str]]]] = No pulumi.export("exampleTeams", example_teams_teams) ``` """ - ... + __args__ = dict() + __args__['names'] = names + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getTeams:getTeams', __args__, opts=opts, typ=GetTeamsResult) + return __ret__.apply(lambda __response__: GetTeamsResult( + id=pulumi.get(__response__, 'id'), + names=pulumi.get(__response__, 'names'), + teams=pulumi.get(__response__, 'teams'))) diff --git a/sdk/python/pulumi_astronomer/get_user.py b/sdk/python/pulumi_astronomer/get_user.py index 2e07bd3..2807b68 100644 --- a/sdk/python/pulumi_astronomer/get_user.py +++ b/sdk/python/pulumi_astronomer/get_user.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -187,9 +192,6 @@ def get_user(id: Optional[str] = None, updated_at=pulumi.get(__ret__, 'updated_at'), username=pulumi.get(__ret__, 'username'), workspace_roles=pulumi.get(__ret__, 'workspace_roles')) - - -@_utilities.lift_output_func(get_user) def get_user_output(id: Optional[pulumi.Input[str]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetUserResult]: """ @@ -208,4 +210,18 @@ def get_user_output(id: Optional[pulumi.Input[str]] = None, :param str id: User identifier """ - ... + __args__ = dict() + __args__['id'] = id + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getUser:getUser', __args__, opts=opts, typ=GetUserResult) + return __ret__.apply(lambda __response__: GetUserResult( + avatar_url=pulumi.get(__response__, 'avatar_url'), + created_at=pulumi.get(__response__, 'created_at'), + deployment_roles=pulumi.get(__response__, 'deployment_roles'), + full_name=pulumi.get(__response__, 'full_name'), + id=pulumi.get(__response__, 'id'), + organization_role=pulumi.get(__response__, 'organization_role'), + status=pulumi.get(__response__, 'status'), + updated_at=pulumi.get(__response__, 'updated_at'), + username=pulumi.get(__response__, 'username'), + workspace_roles=pulumi.get(__response__, 'workspace_roles'))) diff --git a/sdk/python/pulumi_astronomer/get_users.py b/sdk/python/pulumi_astronomer/get_users.py index 2b62ab2..5a8d332 100644 --- a/sdk/python/pulumi_astronomer/get_users.py +++ b/sdk/python/pulumi_astronomer/get_users.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -101,9 +106,6 @@ def get_users(deployment_id: Optional[str] = None, id=pulumi.get(__ret__, 'id'), users=pulumi.get(__ret__, 'users'), workspace_id=pulumi.get(__ret__, 'workspace_id')) - - -@_utilities.lift_output_func(get_users) def get_users_output(deployment_id: Optional[pulumi.Input[Optional[str]]] = None, workspace_id: Optional[pulumi.Input[Optional[str]]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetUsersResult]: @@ -122,4 +124,13 @@ def get_users_output(deployment_id: Optional[pulumi.Input[Optional[str]]] = None pulumi.export("exampleUsers", example_users_users) ``` """ - ... + __args__ = dict() + __args__['deploymentId'] = deployment_id + __args__['workspaceId'] = workspace_id + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getUsers:getUsers', __args__, opts=opts, typ=GetUsersResult) + return __ret__.apply(lambda __response__: GetUsersResult( + deployment_id=pulumi.get(__response__, 'deployment_id'), + id=pulumi.get(__response__, 'id'), + users=pulumi.get(__response__, 'users'), + workspace_id=pulumi.get(__response__, 'workspace_id'))) diff --git a/sdk/python/pulumi_astronomer/get_workspace.py b/sdk/python/pulumi_astronomer/get_workspace.py index a9c18d2..4ce4ddc 100644 --- a/sdk/python/pulumi_astronomer/get_workspace.py +++ b/sdk/python/pulumi_astronomer/get_workspace.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -161,9 +166,6 @@ def get_workspace(id: Optional[str] = None, name=pulumi.get(__ret__, 'name'), updated_at=pulumi.get(__ret__, 'updated_at'), updated_by=pulumi.get(__ret__, 'updated_by')) - - -@_utilities.lift_output_func(get_workspace) def get_workspace_output(id: Optional[pulumi.Input[str]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetWorkspaceResult]: """ @@ -182,4 +184,16 @@ def get_workspace_output(id: Optional[pulumi.Input[str]] = None, :param str id: Workspace identifier """ - ... + __args__ = dict() + __args__['id'] = id + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getWorkspace:getWorkspace', __args__, opts=opts, typ=GetWorkspaceResult) + return __ret__.apply(lambda __response__: GetWorkspaceResult( + cicd_enforced_default=pulumi.get(__response__, 'cicd_enforced_default'), + created_at=pulumi.get(__response__, 'created_at'), + created_by=pulumi.get(__response__, 'created_by'), + description=pulumi.get(__response__, 'description'), + id=pulumi.get(__response__, 'id'), + name=pulumi.get(__response__, 'name'), + updated_at=pulumi.get(__response__, 'updated_at'), + updated_by=pulumi.get(__response__, 'updated_by'))) diff --git a/sdk/python/pulumi_astronomer/get_workspaces.py b/sdk/python/pulumi_astronomer/get_workspaces.py index c402c46..0f0179c 100644 --- a/sdk/python/pulumi_astronomer/get_workspaces.py +++ b/sdk/python/pulumi_astronomer/get_workspaces.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs @@ -107,9 +112,6 @@ def get_workspaces(names: Optional[Sequence[str]] = None, names=pulumi.get(__ret__, 'names'), workspace_ids=pulumi.get(__ret__, 'workspace_ids'), workspaces=pulumi.get(__ret__, 'workspaces')) - - -@_utilities.lift_output_func(get_workspaces) def get_workspaces_output(names: Optional[pulumi.Input[Optional[Sequence[str]]]] = None, workspace_ids: Optional[pulumi.Input[Optional[Sequence[str]]]] = None, opts: Optional[pulumi.InvokeOptions] = None) -> pulumi.Output[GetWorkspacesResult]: @@ -134,4 +136,13 @@ def get_workspaces_output(names: Optional[pulumi.Input[Optional[Sequence[str]]]] pulumi.export("exampleWorkspaces", example_workspaces_workspaces) ``` """ - ... + __args__ = dict() + __args__['names'] = names + __args__['workspaceIds'] = workspace_ids + opts = pulumi.InvokeOptions.merge(_utilities.get_invoke_opts_defaults(), opts) + __ret__ = pulumi.runtime.invoke_output('astronomer:index/getWorkspaces:getWorkspaces', __args__, opts=opts, typ=GetWorkspacesResult) + return __ret__.apply(lambda __response__: GetWorkspacesResult( + id=pulumi.get(__response__, 'id'), + names=pulumi.get(__response__, 'names'), + workspace_ids=pulumi.get(__response__, 'workspace_ids'), + workspaces=pulumi.get(__response__, 'workspaces'))) diff --git a/sdk/python/pulumi_astronomer/hybrid_cluster_workspace_authorization.py b/sdk/python/pulumi_astronomer/hybrid_cluster_workspace_authorization.py index 2ba1cd7..2473a93 100644 --- a/sdk/python/pulumi_astronomer/hybrid_cluster_workspace_authorization.py +++ b/sdk/python/pulumi_astronomer/hybrid_cluster_workspace_authorization.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities __all__ = ['HybridClusterWorkspaceAuthorizationArgs', 'HybridClusterWorkspaceAuthorization'] diff --git a/sdk/python/pulumi_astronomer/outputs.py b/sdk/python/pulumi_astronomer/outputs.py index b3803f0..db99a93 100644 --- a/sdk/python/pulumi_astronomer/outputs.py +++ b/sdk/python/pulumi_astronomer/outputs.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs diff --git a/sdk/python/pulumi_astronomer/provider.py b/sdk/python/pulumi_astronomer/provider.py index 76d0a2b..80e388b 100644 --- a/sdk/python/pulumi_astronomer/provider.py +++ b/sdk/python/pulumi_astronomer/provider.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities __all__ = ['ProviderArgs', 'Provider'] diff --git a/sdk/python/pulumi_astronomer/team.py b/sdk/python/pulumi_astronomer/team.py index 2eb6ec0..80f503d 100644 --- a/sdk/python/pulumi_astronomer/team.py +++ b/sdk/python/pulumi_astronomer/team.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs from ._inputs import * diff --git a/sdk/python/pulumi_astronomer/team_roles.py b/sdk/python/pulumi_astronomer/team_roles.py index f582e65..afc4d9d 100644 --- a/sdk/python/pulumi_astronomer/team_roles.py +++ b/sdk/python/pulumi_astronomer/team_roles.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs from ._inputs import * diff --git a/sdk/python/pulumi_astronomer/user_invite.py b/sdk/python/pulumi_astronomer/user_invite.py index 7468f8e..280d769 100644 --- a/sdk/python/pulumi_astronomer/user_invite.py +++ b/sdk/python/pulumi_astronomer/user_invite.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs from ._inputs import * diff --git a/sdk/python/pulumi_astronomer/user_roles.py b/sdk/python/pulumi_astronomer/user_roles.py index 3d73f7a..9eed55a 100644 --- a/sdk/python/pulumi_astronomer/user_roles.py +++ b/sdk/python/pulumi_astronomer/user_roles.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs from ._inputs import * diff --git a/sdk/python/pulumi_astronomer/workspace.py b/sdk/python/pulumi_astronomer/workspace.py index ed3c2b6..e1c75b1 100644 --- a/sdk/python/pulumi_astronomer/workspace.py +++ b/sdk/python/pulumi_astronomer/workspace.py @@ -4,9 +4,14 @@ import copy import warnings +import sys import pulumi import pulumi.runtime from typing import Any, Mapping, Optional, Sequence, Union, overload +if sys.version_info >= (3, 11): + from typing import NotRequired, TypedDict, TypeAlias +else: + from typing_extensions import NotRequired, TypedDict, TypeAlias from . import _utilities from . import outputs from ._inputs import * diff --git a/sdk/python/setup.py b/sdk/python/setup.py index d3481e5..b025a69 100644 --- a/sdk/python/setup.py +++ b/sdk/python/setup.py @@ -39,6 +39,7 @@ def readme(): install_requires=[ 'parver>=0.2.1', 'pulumi>=3.0.0,<4.0.0', - 'semver>=2.8.1' + 'semver>=2.8.1', + 'typing-extensions>=4.11,<5; python_version < "3.11"' ], zip_safe=False)