diff --git a/provider/cmd/pulumi-resource-databricks/bridge-metadata.json b/provider/cmd/pulumi-resource-databricks/bridge-metadata.json index 3d777045..2fd02188 100644 --- a/provider/cmd/pulumi-resource-databricks/bridge-metadata.json +++ b/provider/cmd/pulumi-resource-databricks/bridge-metadata.json @@ -2473,6 +2473,9 @@ } } }, + "restart_window": { + "maxItemsOne": true + }, "trigger": { "maxItemsOne": true, "elem": { diff --git a/provider/cmd/pulumi-resource-databricks/schema.json b/provider/cmd/pulumi-resource-databricks/schema.json index 56abab0b..a0f03433 100644 --- a/provider/cmd/pulumi-resource-databricks/schema.json +++ b/provider/cmd/pulumi-resource-databricks/schema.json @@ -8346,6 +8346,9 @@ "description": "Immutable. The Unity Catalog connection this gateway pipeline uses to communicate with the source.\n", "willReplaceOnChanges": true }, + "connectionName": { + "type": "string" + }, "gatewayStorageCatalog": { "type": "string", "description": "Required, Immutable. The name of the catalog for the gateway pipeline's storage location.\n", @@ -8648,6 +8651,23 @@ }, "type": "object" }, + "databricks:index/PipelineRestartWindow:PipelineRestartWindow": { + "properties": { + "daysOfWeek": { + "type": "string" + }, + "startHour": { + "type": "integer" + }, + "timeZoneId": { + "type": "string" + } + }, + "type": "object", + "required": [ + "startHour" + ] + }, "databricks:index/PipelineTrigger:PipelineTrigger": { "properties": { "cron": { @@ -16916,6 +16936,9 @@ "$ref": "#/types/databricks:index/getStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccount:getStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccount", "description": "credential details for GCP:\n" }, + "fullName": { + "type": "string" + }, "id": { "type": "string", "description": "Unique ID of storage credential.\n" @@ -25892,6 +25915,9 @@ "type": "boolean", "description": "A flag indicating whether to use Photon engine. The default value is `false`.\n" }, + "restartWindow": { + "$ref": "#/types/databricks:index/PipelineRestartWindow:PipelineRestartWindow" + }, "runAsUserName": { "type": "string" }, @@ -26038,6 +26064,9 @@ "type": "boolean", "description": "A flag indicating whether to use Photon engine. The default value is `false`.\n" }, + "restartWindow": { + "$ref": "#/types/databricks:index/PipelineRestartWindow:PipelineRestartWindow" + }, "runAsUserName": { "type": "string" }, @@ -26175,6 +26204,9 @@ "type": "boolean", "description": "A flag indicating whether to use Photon engine. The default value is `false`.\n" }, + "restartWindow": { + "$ref": "#/types/databricks:index/PipelineRestartWindow:PipelineRestartWindow" + }, "runAsUserName": { "type": "string" }, diff --git a/provider/go.mod b/provider/go.mod index b77452d4..b88740ac 100644 --- a/provider/go.mod +++ b/provider/go.mod @@ -7,7 +7,7 @@ replace github.com/hashicorp/terraform-plugin-sdk/v2 => github.com/pulumi/terraf replace github.com/databricks/terraform-provider-databricks/shim => ./shim require ( - github.com/databricks/databricks-sdk-go v0.50.0 + github.com/databricks/databricks-sdk-go v0.51.0 github.com/databricks/terraform-provider-databricks/shim v0.0.0-00010101000000-000000000000 github.com/pulumi/providertest v0.1.3 github.com/pulumi/pulumi-terraform-bridge/v3 v3.95.0 @@ -47,7 +47,7 @@ require ( github.com/cloudflare/circl v1.3.7 // indirect github.com/containerd/console v1.0.4-0.20230313162750-1ae8d489ac81 // indirect github.com/cyphar/filepath-securejoin v0.2.4 // indirect - github.com/databricks/terraform-provider-databricks v1.57.0 // indirect + github.com/databricks/terraform-provider-databricks v1.58.0 // indirect github.com/davecgh/go-spew v1.1.1 // indirect github.com/deckarep/golang-set/v2 v2.5.0 // indirect github.com/djherbis/times v1.5.0 // indirect @@ -65,7 +65,7 @@ require ( github.com/go-logr/stdr v1.2.2 // indirect github.com/gofrs/uuid v4.3.1+incompatible // indirect github.com/gogo/protobuf v1.3.2 // indirect - github.com/golang-jwt/jwt/v4 v4.5.0 // indirect + github.com/golang-jwt/jwt/v4 v4.5.1 // indirect github.com/golang/glog v1.2.2 // indirect github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect github.com/golang/protobuf v1.5.4 // indirect diff --git a/provider/go.sum b/provider/go.sum index dcff5bf1..85881e1e 100644 --- a/provider/go.sum +++ b/provider/go.sum @@ -1320,10 +1320,10 @@ github.com/cpuguy83/go-md2man/v2 v2.0.3/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46t github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E= github.com/cyphar/filepath-securejoin v0.2.4 h1:Ugdm7cg7i6ZK6x3xDF1oEu1nfkyfH53EtKeQYTC3kyg= github.com/cyphar/filepath-securejoin v0.2.4/go.mod h1:aPGpWjXOXUn2NCNjFvBE6aRxGGx79pTxQpKOJNYHHl4= -github.com/databricks/databricks-sdk-go v0.50.0 h1:Zl4uBhYMT5z6aDojCQJPT2zCYjjfqxBQSQn8uLTphpo= -github.com/databricks/databricks-sdk-go v0.50.0/go.mod h1:ds+zbv5mlQG7nFEU5ojLtgN/u0/9YzZmKQES/CfedzU= -github.com/databricks/terraform-provider-databricks v1.57.0 h1:weBPeeeC7XGcQQGPtU1NV9/TB/X6wLGEHhkjmYq7Ywo= -github.com/databricks/terraform-provider-databricks v1.57.0/go.mod h1:OmWb7za9zIoMhV1y2Z43l5FO9g/2GeDUUcp6r/FzMEQ= +github.com/databricks/databricks-sdk-go v0.51.0 h1:tcvB9TID3oUl0O8npccB5c+33tarBiYMBFbq4U4AB6M= +github.com/databricks/databricks-sdk-go v0.51.0/go.mod h1:ds+zbv5mlQG7nFEU5ojLtgN/u0/9YzZmKQES/CfedzU= +github.com/databricks/terraform-provider-databricks v1.58.0 h1:lSDi6FsdM3CxhIW7Cw4QfZ1D5F3dAkbRi8ONikY2rrE= +github.com/databricks/terraform-provider-databricks v1.58.0/go.mod h1:oSEHBD43kknIyc6tWvjzJS+FvgdgrE2NgCtglMsrIEQ= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= @@ -1431,8 +1431,8 @@ github.com/gofrs/uuid v4.3.1+incompatible/go.mod h1:b2aQJv3Z4Fp6yNu3cdSllBxTCLRx github.com/gogo/protobuf v1.3.1/go.mod h1:SlYgWuQ5SjCEi6WLHjHCa1yvBfUnHcTbrrZtXPKa29o= github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q= github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q= -github.com/golang-jwt/jwt/v4 v4.5.0 h1:7cYmW1XlMY7h7ii7UhUyChSgS5wUJEnm9uZVTGqOWzg= -github.com/golang-jwt/jwt/v4 v4.5.0/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0= +github.com/golang-jwt/jwt/v4 v4.5.1 h1:JdqV9zKUdtaa9gdPlywC3aeoEsR681PlKC+4F5gQgeo= +github.com/golang-jwt/jwt/v4 v4.5.1/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0= github.com/golang-jwt/jwt/v5 v5.2.1 h1:OuVbFODueb089Lh128TAcimifWaLhJwVflnrgM17wHk= github.com/golang-jwt/jwt/v5 v5.2.1/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk= github.com/golang/freetype v0.0.0-20170609003504-e2365dfdc4a0/go.mod h1:E/TSTwGwJL78qG/PmXZO1EjYhfJinVAhrmmHX6Z8B9k= diff --git a/provider/shim/go.mod b/provider/shim/go.mod index 2f6557c8..c97b69cf 100644 --- a/provider/shim/go.mod +++ b/provider/shim/go.mod @@ -3,7 +3,7 @@ module github.com/databricks/terraform-provider-databricks/shim go 1.23.0 require ( - github.com/databricks/terraform-provider-databricks v1.57.0 + github.com/databricks/terraform-provider-databricks v1.58.0 github.com/hashicorp/terraform-plugin-framework v1.11.0 github.com/hashicorp/terraform-plugin-sdk/v2 v2.34.0 ) @@ -16,12 +16,12 @@ require ( github.com/agext/levenshtein v1.2.3 // indirect github.com/apparentlymart/go-textseg/v15 v15.0.0 // indirect github.com/cloudflare/circl v1.3.7 // indirect - github.com/databricks/databricks-sdk-go v0.50.0 // indirect + github.com/databricks/databricks-sdk-go v0.51.0 // indirect github.com/fatih/color v1.16.0 // indirect github.com/felixge/httpsnoop v1.0.4 // indirect github.com/go-logr/logr v1.4.1 // indirect github.com/go-logr/stdr v1.2.2 // indirect - github.com/golang-jwt/jwt/v4 v4.5.0 // indirect + github.com/golang-jwt/jwt/v4 v4.5.1 // indirect github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect github.com/golang/protobuf v1.5.4 // indirect github.com/google/go-cmp v0.6.0 // indirect diff --git a/provider/shim/go.sum b/provider/shim/go.sum index c1e4d7ea..9f8a2bbd 100644 --- a/provider/shim/go.sum +++ b/provider/shim/go.sum @@ -26,10 +26,10 @@ github.com/cloudflare/circl v1.3.7/go.mod h1:sRTcRWXGLrKw6yIGJ+l7amYJFfAXbZG0kBS github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc= github.com/cyphar/filepath-securejoin v0.2.4 h1:Ugdm7cg7i6ZK6x3xDF1oEu1nfkyfH53EtKeQYTC3kyg= github.com/cyphar/filepath-securejoin v0.2.4/go.mod h1:aPGpWjXOXUn2NCNjFvBE6aRxGGx79pTxQpKOJNYHHl4= -github.com/databricks/databricks-sdk-go v0.50.0 h1:Zl4uBhYMT5z6aDojCQJPT2zCYjjfqxBQSQn8uLTphpo= -github.com/databricks/databricks-sdk-go v0.50.0/go.mod h1:ds+zbv5mlQG7nFEU5ojLtgN/u0/9YzZmKQES/CfedzU= -github.com/databricks/terraform-provider-databricks v1.57.0 h1:weBPeeeC7XGcQQGPtU1NV9/TB/X6wLGEHhkjmYq7Ywo= -github.com/databricks/terraform-provider-databricks v1.57.0/go.mod h1:OmWb7za9zIoMhV1y2Z43l5FO9g/2GeDUUcp6r/FzMEQ= +github.com/databricks/databricks-sdk-go v0.51.0 h1:tcvB9TID3oUl0O8npccB5c+33tarBiYMBFbq4U4AB6M= +github.com/databricks/databricks-sdk-go v0.51.0/go.mod h1:ds+zbv5mlQG7nFEU5ojLtgN/u0/9YzZmKQES/CfedzU= +github.com/databricks/terraform-provider-databricks v1.58.0 h1:lSDi6FsdM3CxhIW7Cw4QfZ1D5F3dAkbRi8ONikY2rrE= +github.com/databricks/terraform-provider-databricks v1.58.0/go.mod h1:oSEHBD43kknIyc6tWvjzJS+FvgdgrE2NgCtglMsrIEQ= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= @@ -57,8 +57,8 @@ github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag= github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE= github.com/go-test/deep v1.0.3 h1:ZrJSEWsXzPOxaZnFteGEfooLba+ju3FYIbOrS+rQd68= github.com/go-test/deep v1.0.3/go.mod h1:wGDj63lr65AM2AQyKZd/NYHGb0R+1RLqB8NKt3aSFNA= -github.com/golang-jwt/jwt/v4 v4.5.0 h1:7cYmW1XlMY7h7ii7UhUyChSgS5wUJEnm9uZVTGqOWzg= -github.com/golang-jwt/jwt/v4 v4.5.0/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0= +github.com/golang-jwt/jwt/v4 v4.5.1 h1:JdqV9zKUdtaa9gdPlywC3aeoEsR681PlKC+4F5gQgeo= +github.com/golang-jwt/jwt/v4 v4.5.1/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0= github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q= github.com/golang/groupcache v0.0.0-20200121045136-8c9f03a8e57e/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc= github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da h1:oI5xCqsCo564l8iNU+DwB5epxmsaqB+rhGL0m5jtYqE= diff --git a/sdk/dotnet/Inputs/GetStorageCredentialStorageCredentialInfo.cs b/sdk/dotnet/Inputs/GetStorageCredentialStorageCredentialInfo.cs index 02325b75..3d34401b 100644 --- a/sdk/dotnet/Inputs/GetStorageCredentialStorageCredentialInfo.cs +++ b/sdk/dotnet/Inputs/GetStorageCredentialStorageCredentialInfo.cs @@ -54,6 +54,9 @@ public sealed class GetStorageCredentialStorageCredentialInfoArgs : global::Pulu [Input("databricksGcpServiceAccount")] public Inputs.GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccountArgs? DatabricksGcpServiceAccount { get; set; } + [Input("fullName")] + public string? FullName { get; set; } + /// /// Unique ID of storage credential. /// diff --git a/sdk/dotnet/Inputs/GetStorageCredentialStorageCredentialInfoArgs.cs b/sdk/dotnet/Inputs/GetStorageCredentialStorageCredentialInfoArgs.cs index aca1fd84..f26a5c0b 100644 --- a/sdk/dotnet/Inputs/GetStorageCredentialStorageCredentialInfoArgs.cs +++ b/sdk/dotnet/Inputs/GetStorageCredentialStorageCredentialInfoArgs.cs @@ -54,6 +54,9 @@ public sealed class GetStorageCredentialStorageCredentialInfoInputArgs : global: [Input("databricksGcpServiceAccount")] public Input? DatabricksGcpServiceAccount { get; set; } + [Input("fullName")] + public Input? FullName { get; set; } + /// /// Unique ID of storage credential. /// diff --git a/sdk/dotnet/Inputs/PipelineGatewayDefinitionArgs.cs b/sdk/dotnet/Inputs/PipelineGatewayDefinitionArgs.cs index 24a67e7a..97dc611e 100644 --- a/sdk/dotnet/Inputs/PipelineGatewayDefinitionArgs.cs +++ b/sdk/dotnet/Inputs/PipelineGatewayDefinitionArgs.cs @@ -18,6 +18,9 @@ public sealed class PipelineGatewayDefinitionArgs : global::Pulumi.ResourceArgs [Input("connectionId")] public Input? ConnectionId { get; set; } + [Input("connectionName")] + public Input? ConnectionName { get; set; } + /// /// Required, Immutable. The name of the catalog for the gateway pipeline's storage location. /// diff --git a/sdk/dotnet/Inputs/PipelineGatewayDefinitionGetArgs.cs b/sdk/dotnet/Inputs/PipelineGatewayDefinitionGetArgs.cs index 9cb27ec9..2fcae4e1 100644 --- a/sdk/dotnet/Inputs/PipelineGatewayDefinitionGetArgs.cs +++ b/sdk/dotnet/Inputs/PipelineGatewayDefinitionGetArgs.cs @@ -18,6 +18,9 @@ public sealed class PipelineGatewayDefinitionGetArgs : global::Pulumi.ResourceAr [Input("connectionId")] public Input? ConnectionId { get; set; } + [Input("connectionName")] + public Input? ConnectionName { get; set; } + /// /// Required, Immutable. The name of the catalog for the gateway pipeline's storage location. /// diff --git a/sdk/dotnet/Inputs/PipelineRestartWindowArgs.cs b/sdk/dotnet/Inputs/PipelineRestartWindowArgs.cs new file mode 100644 index 00000000..e1da49d4 --- /dev/null +++ b/sdk/dotnet/Inputs/PipelineRestartWindowArgs.cs @@ -0,0 +1,29 @@ +// *** WARNING: this file was generated by the Pulumi Terraform Bridge (tfgen) Tool. *** +// *** Do not edit by hand unless you're certain you know what you are doing! *** + +using System; +using System.Collections.Generic; +using System.Collections.Immutable; +using System.Threading.Tasks; +using Pulumi.Serialization; + +namespace Pulumi.Databricks.Inputs +{ + + public sealed class PipelineRestartWindowArgs : global::Pulumi.ResourceArgs + { + [Input("daysOfWeek")] + public Input? DaysOfWeek { get; set; } + + [Input("startHour", required: true)] + public Input StartHour { get; set; } = null!; + + [Input("timeZoneId")] + public Input? TimeZoneId { get; set; } + + public PipelineRestartWindowArgs() + { + } + public static new PipelineRestartWindowArgs Empty => new PipelineRestartWindowArgs(); + } +} diff --git a/sdk/dotnet/Inputs/PipelineRestartWindowGetArgs.cs b/sdk/dotnet/Inputs/PipelineRestartWindowGetArgs.cs new file mode 100644 index 00000000..a4383231 --- /dev/null +++ b/sdk/dotnet/Inputs/PipelineRestartWindowGetArgs.cs @@ -0,0 +1,29 @@ +// *** WARNING: this file was generated by the Pulumi Terraform Bridge (tfgen) Tool. *** +// *** Do not edit by hand unless you're certain you know what you are doing! *** + +using System; +using System.Collections.Generic; +using System.Collections.Immutable; +using System.Threading.Tasks; +using Pulumi.Serialization; + +namespace Pulumi.Databricks.Inputs +{ + + public sealed class PipelineRestartWindowGetArgs : global::Pulumi.ResourceArgs + { + [Input("daysOfWeek")] + public Input? DaysOfWeek { get; set; } + + [Input("startHour", required: true)] + public Input StartHour { get; set; } = null!; + + [Input("timeZoneId")] + public Input? TimeZoneId { get; set; } + + public PipelineRestartWindowGetArgs() + { + } + public static new PipelineRestartWindowGetArgs Empty => new PipelineRestartWindowGetArgs(); + } +} diff --git a/sdk/dotnet/Outputs/GetStorageCredentialStorageCredentialInfoResult.cs b/sdk/dotnet/Outputs/GetStorageCredentialStorageCredentialInfoResult.cs index 0b781afe..6c753b66 100644 --- a/sdk/dotnet/Outputs/GetStorageCredentialStorageCredentialInfoResult.cs +++ b/sdk/dotnet/Outputs/GetStorageCredentialStorageCredentialInfoResult.cs @@ -39,6 +39,7 @@ public sealed class GetStorageCredentialStorageCredentialInfoResult /// credential details for GCP: /// public readonly Outputs.GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccountResult? DatabricksGcpServiceAccount; + public readonly string? FullName; /// /// Unique ID of storage credential. /// @@ -88,6 +89,8 @@ private GetStorageCredentialStorageCredentialInfoResult( Outputs.GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccountResult? databricksGcpServiceAccount, + string? fullName, + string? id, string? isolationMode, @@ -114,6 +117,7 @@ private GetStorageCredentialStorageCredentialInfoResult( CreatedAt = createdAt; CreatedBy = createdBy; DatabricksGcpServiceAccount = databricksGcpServiceAccount; + FullName = fullName; Id = id; IsolationMode = isolationMode; MetastoreId = metastoreId; diff --git a/sdk/dotnet/Outputs/PipelineGatewayDefinition.cs b/sdk/dotnet/Outputs/PipelineGatewayDefinition.cs index d6ed8fb1..30ddf730 100644 --- a/sdk/dotnet/Outputs/PipelineGatewayDefinition.cs +++ b/sdk/dotnet/Outputs/PipelineGatewayDefinition.cs @@ -17,6 +17,7 @@ public sealed class PipelineGatewayDefinition /// Immutable. The Unity Catalog connection this gateway pipeline uses to communicate with the source. /// public readonly string? ConnectionId; + public readonly string? ConnectionName; /// /// Required, Immutable. The name of the catalog for the gateway pipeline's storage location. /// @@ -34,6 +35,8 @@ public sealed class PipelineGatewayDefinition private PipelineGatewayDefinition( string? connectionId, + string? connectionName, + string? gatewayStorageCatalog, string? gatewayStorageName, @@ -41,6 +44,7 @@ private PipelineGatewayDefinition( string? gatewayStorageSchema) { ConnectionId = connectionId; + ConnectionName = connectionName; GatewayStorageCatalog = gatewayStorageCatalog; GatewayStorageName = gatewayStorageName; GatewayStorageSchema = gatewayStorageSchema; diff --git a/sdk/dotnet/Outputs/PipelineRestartWindow.cs b/sdk/dotnet/Outputs/PipelineRestartWindow.cs new file mode 100644 index 00000000..c2c6ef8f --- /dev/null +++ b/sdk/dotnet/Outputs/PipelineRestartWindow.cs @@ -0,0 +1,33 @@ +// *** WARNING: this file was generated by the Pulumi Terraform Bridge (tfgen) Tool. *** +// *** Do not edit by hand unless you're certain you know what you are doing! *** + +using System; +using System.Collections.Generic; +using System.Collections.Immutable; +using System.Threading.Tasks; +using Pulumi.Serialization; + +namespace Pulumi.Databricks.Outputs +{ + + [OutputType] + public sealed class PipelineRestartWindow + { + public readonly string? DaysOfWeek; + public readonly int StartHour; + public readonly string? TimeZoneId; + + [OutputConstructor] + private PipelineRestartWindow( + string? daysOfWeek, + + int startHour, + + string? timeZoneId) + { + DaysOfWeek = daysOfWeek; + StartHour = startHour; + TimeZoneId = timeZoneId; + } + } +} diff --git a/sdk/dotnet/Pipeline.cs b/sdk/dotnet/Pipeline.cs index d6a8eb87..5837690a 100644 --- a/sdk/dotnet/Pipeline.cs +++ b/sdk/dotnet/Pipeline.cs @@ -237,6 +237,9 @@ public partial class Pipeline : global::Pulumi.CustomResource [Output("photon")] public Output Photon { get; private set; } = null!; + [Output("restartWindow")] + public Output RestartWindow { get; private set; } = null!; + [Output("runAsUserName")] public Output RunAsUserName { get; private set; } = null!; @@ -467,6 +470,9 @@ public InputList Notifications [Input("photon")] public Input? Photon { get; set; } + [Input("restartWindow")] + public Input? RestartWindow { get; set; } + [Input("runAsUserName")] public Input? RunAsUserName { get; set; } @@ -659,6 +665,9 @@ public InputList Notifications [Input("photon")] public Input? Photon { get; set; } + [Input("restartWindow")] + public Input? RestartWindow { get; set; } + [Input("runAsUserName")] public Input? RunAsUserName { get; set; } diff --git a/sdk/go/databricks/pipeline.go b/sdk/go/databricks/pipeline.go index e9e564c9..75799653 100644 --- a/sdk/go/databricks/pipeline.go +++ b/sdk/go/databricks/pipeline.go @@ -159,8 +159,9 @@ type Pipeline struct { Name pulumi.StringOutput `pulumi:"name"` Notifications PipelineNotificationArrayOutput `pulumi:"notifications"` // A flag indicating whether to use Photon engine. The default value is `false`. - Photon pulumi.BoolPtrOutput `pulumi:"photon"` - RunAsUserName pulumi.StringOutput `pulumi:"runAsUserName"` + Photon pulumi.BoolPtrOutput `pulumi:"photon"` + RestartWindow PipelineRestartWindowPtrOutput `pulumi:"restartWindow"` + RunAsUserName pulumi.StringOutput `pulumi:"runAsUserName"` // The default schema (database) where tables are read from or published to. The presence of this attribute implies that the pipeline is in direct publishing mode. Schema pulumi.StringPtrOutput `pulumi:"schema"` // An optional flag indicating if serverless compute should be used for this DLT pipeline. Requires `catalog` to be set, as it could be used only with Unity Catalog. @@ -243,8 +244,9 @@ type pipelineState struct { Name *string `pulumi:"name"` Notifications []PipelineNotification `pulumi:"notifications"` // A flag indicating whether to use Photon engine. The default value is `false`. - Photon *bool `pulumi:"photon"` - RunAsUserName *string `pulumi:"runAsUserName"` + Photon *bool `pulumi:"photon"` + RestartWindow *PipelineRestartWindow `pulumi:"restartWindow"` + RunAsUserName *string `pulumi:"runAsUserName"` // The default schema (database) where tables are read from or published to. The presence of this attribute implies that the pipeline is in direct publishing mode. Schema *string `pulumi:"schema"` // An optional flag indicating if serverless compute should be used for this DLT pipeline. Requires `catalog` to be set, as it could be used only with Unity Catalog. @@ -299,6 +301,7 @@ type PipelineState struct { Notifications PipelineNotificationArrayInput // A flag indicating whether to use Photon engine. The default value is `false`. Photon pulumi.BoolPtrInput + RestartWindow PipelineRestartWindowPtrInput RunAsUserName pulumi.StringPtrInput // The default schema (database) where tables are read from or published to. The presence of this attribute implies that the pipeline is in direct publishing mode. Schema pulumi.StringPtrInput @@ -357,8 +360,9 @@ type pipelineArgs struct { Name *string `pulumi:"name"` Notifications []PipelineNotification `pulumi:"notifications"` // A flag indicating whether to use Photon engine. The default value is `false`. - Photon *bool `pulumi:"photon"` - RunAsUserName *string `pulumi:"runAsUserName"` + Photon *bool `pulumi:"photon"` + RestartWindow *PipelineRestartWindow `pulumi:"restartWindow"` + RunAsUserName *string `pulumi:"runAsUserName"` // The default schema (database) where tables are read from or published to. The presence of this attribute implies that the pipeline is in direct publishing mode. Schema *string `pulumi:"schema"` // An optional flag indicating if serverless compute should be used for this DLT pipeline. Requires `catalog` to be set, as it could be used only with Unity Catalog. @@ -414,6 +418,7 @@ type PipelineArgs struct { Notifications PipelineNotificationArrayInput // A flag indicating whether to use Photon engine. The default value is `false`. Photon pulumi.BoolPtrInput + RestartWindow PipelineRestartWindowPtrInput RunAsUserName pulumi.StringPtrInput // The default schema (database) where tables are read from or published to. The presence of this attribute implies that the pipeline is in direct publishing mode. Schema pulumi.StringPtrInput @@ -627,6 +632,10 @@ func (o PipelineOutput) Photon() pulumi.BoolPtrOutput { return o.ApplyT(func(v *Pipeline) pulumi.BoolPtrOutput { return v.Photon }).(pulumi.BoolPtrOutput) } +func (o PipelineOutput) RestartWindow() PipelineRestartWindowPtrOutput { + return o.ApplyT(func(v *Pipeline) PipelineRestartWindowPtrOutput { return v.RestartWindow }).(PipelineRestartWindowPtrOutput) +} + func (o PipelineOutput) RunAsUserName() pulumi.StringOutput { return o.ApplyT(func(v *Pipeline) pulumi.StringOutput { return v.RunAsUserName }).(pulumi.StringOutput) } diff --git a/sdk/go/databricks/pulumiTypes.go b/sdk/go/databricks/pulumiTypes.go index a3ea3057..d3dac05e 100644 --- a/sdk/go/databricks/pulumiTypes.go +++ b/sdk/go/databricks/pulumiTypes.go @@ -64483,7 +64483,8 @@ func (o PipelineFiltersPtrOutput) Includes() pulumi.StringArrayOutput { type PipelineGatewayDefinition struct { // Immutable. The Unity Catalog connection this gateway pipeline uses to communicate with the source. - ConnectionId *string `pulumi:"connectionId"` + ConnectionId *string `pulumi:"connectionId"` + ConnectionName *string `pulumi:"connectionName"` // Required, Immutable. The name of the catalog for the gateway pipeline's storage location. GatewayStorageCatalog *string `pulumi:"gatewayStorageCatalog"` // Required. The Unity Catalog-compatible naming for the gateway storage location. This is the destination to use for the data that is extracted by the gateway. Delta Live Tables system will automatically create the storage location under the catalog and schema. @@ -64505,7 +64506,8 @@ type PipelineGatewayDefinitionInput interface { type PipelineGatewayDefinitionArgs struct { // Immutable. The Unity Catalog connection this gateway pipeline uses to communicate with the source. - ConnectionId pulumi.StringPtrInput `pulumi:"connectionId"` + ConnectionId pulumi.StringPtrInput `pulumi:"connectionId"` + ConnectionName pulumi.StringPtrInput `pulumi:"connectionName"` // Required, Immutable. The name of the catalog for the gateway pipeline's storage location. GatewayStorageCatalog pulumi.StringPtrInput `pulumi:"gatewayStorageCatalog"` // Required. The Unity Catalog-compatible naming for the gateway storage location. This is the destination to use for the data that is extracted by the gateway. Delta Live Tables system will automatically create the storage location under the catalog and schema. @@ -64596,6 +64598,10 @@ func (o PipelineGatewayDefinitionOutput) ConnectionId() pulumi.StringPtrOutput { return o.ApplyT(func(v PipelineGatewayDefinition) *string { return v.ConnectionId }).(pulumi.StringPtrOutput) } +func (o PipelineGatewayDefinitionOutput) ConnectionName() pulumi.StringPtrOutput { + return o.ApplyT(func(v PipelineGatewayDefinition) *string { return v.ConnectionName }).(pulumi.StringPtrOutput) +} + // Required, Immutable. The name of the catalog for the gateway pipeline's storage location. func (o PipelineGatewayDefinitionOutput) GatewayStorageCatalog() pulumi.StringPtrOutput { return o.ApplyT(func(v PipelineGatewayDefinition) *string { return v.GatewayStorageCatalog }).(pulumi.StringPtrOutput) @@ -64645,6 +64651,15 @@ func (o PipelineGatewayDefinitionPtrOutput) ConnectionId() pulumi.StringPtrOutpu }).(pulumi.StringPtrOutput) } +func (o PipelineGatewayDefinitionPtrOutput) ConnectionName() pulumi.StringPtrOutput { + return o.ApplyT(func(v *PipelineGatewayDefinition) *string { + if v == nil { + return nil + } + return v.ConnectionName + }).(pulumi.StringPtrOutput) +} + // Required, Immutable. The name of the catalog for the gateway pipeline's storage location. func (o PipelineGatewayDefinitionPtrOutput) GatewayStorageCatalog() pulumi.StringPtrOutput { return o.ApplyT(func(v *PipelineGatewayDefinition) *string { @@ -67071,6 +67086,169 @@ func (o PipelineNotificationArrayOutput) Index(i pulumi.IntInput) PipelineNotifi }).(PipelineNotificationOutput) } +type PipelineRestartWindow struct { + DaysOfWeek *string `pulumi:"daysOfWeek"` + StartHour int `pulumi:"startHour"` + TimeZoneId *string `pulumi:"timeZoneId"` +} + +// PipelineRestartWindowInput is an input type that accepts PipelineRestartWindowArgs and PipelineRestartWindowOutput values. +// You can construct a concrete instance of `PipelineRestartWindowInput` via: +// +// PipelineRestartWindowArgs{...} +type PipelineRestartWindowInput interface { + pulumi.Input + + ToPipelineRestartWindowOutput() PipelineRestartWindowOutput + ToPipelineRestartWindowOutputWithContext(context.Context) PipelineRestartWindowOutput +} + +type PipelineRestartWindowArgs struct { + DaysOfWeek pulumi.StringPtrInput `pulumi:"daysOfWeek"` + StartHour pulumi.IntInput `pulumi:"startHour"` + TimeZoneId pulumi.StringPtrInput `pulumi:"timeZoneId"` +} + +func (PipelineRestartWindowArgs) ElementType() reflect.Type { + return reflect.TypeOf((*PipelineRestartWindow)(nil)).Elem() +} + +func (i PipelineRestartWindowArgs) ToPipelineRestartWindowOutput() PipelineRestartWindowOutput { + return i.ToPipelineRestartWindowOutputWithContext(context.Background()) +} + +func (i PipelineRestartWindowArgs) ToPipelineRestartWindowOutputWithContext(ctx context.Context) PipelineRestartWindowOutput { + return pulumi.ToOutputWithContext(ctx, i).(PipelineRestartWindowOutput) +} + +func (i PipelineRestartWindowArgs) ToPipelineRestartWindowPtrOutput() PipelineRestartWindowPtrOutput { + return i.ToPipelineRestartWindowPtrOutputWithContext(context.Background()) +} + +func (i PipelineRestartWindowArgs) ToPipelineRestartWindowPtrOutputWithContext(ctx context.Context) PipelineRestartWindowPtrOutput { + return pulumi.ToOutputWithContext(ctx, i).(PipelineRestartWindowOutput).ToPipelineRestartWindowPtrOutputWithContext(ctx) +} + +// PipelineRestartWindowPtrInput is an input type that accepts PipelineRestartWindowArgs, PipelineRestartWindowPtr and PipelineRestartWindowPtrOutput values. +// You can construct a concrete instance of `PipelineRestartWindowPtrInput` via: +// +// PipelineRestartWindowArgs{...} +// +// or: +// +// nil +type PipelineRestartWindowPtrInput interface { + pulumi.Input + + ToPipelineRestartWindowPtrOutput() PipelineRestartWindowPtrOutput + ToPipelineRestartWindowPtrOutputWithContext(context.Context) PipelineRestartWindowPtrOutput +} + +type pipelineRestartWindowPtrType PipelineRestartWindowArgs + +func PipelineRestartWindowPtr(v *PipelineRestartWindowArgs) PipelineRestartWindowPtrInput { + return (*pipelineRestartWindowPtrType)(v) +} + +func (*pipelineRestartWindowPtrType) ElementType() reflect.Type { + return reflect.TypeOf((**PipelineRestartWindow)(nil)).Elem() +} + +func (i *pipelineRestartWindowPtrType) ToPipelineRestartWindowPtrOutput() PipelineRestartWindowPtrOutput { + return i.ToPipelineRestartWindowPtrOutputWithContext(context.Background()) +} + +func (i *pipelineRestartWindowPtrType) ToPipelineRestartWindowPtrOutputWithContext(ctx context.Context) PipelineRestartWindowPtrOutput { + return pulumi.ToOutputWithContext(ctx, i).(PipelineRestartWindowPtrOutput) +} + +type PipelineRestartWindowOutput struct{ *pulumi.OutputState } + +func (PipelineRestartWindowOutput) ElementType() reflect.Type { + return reflect.TypeOf((*PipelineRestartWindow)(nil)).Elem() +} + +func (o PipelineRestartWindowOutput) ToPipelineRestartWindowOutput() PipelineRestartWindowOutput { + return o +} + +func (o PipelineRestartWindowOutput) ToPipelineRestartWindowOutputWithContext(ctx context.Context) PipelineRestartWindowOutput { + return o +} + +func (o PipelineRestartWindowOutput) ToPipelineRestartWindowPtrOutput() PipelineRestartWindowPtrOutput { + return o.ToPipelineRestartWindowPtrOutputWithContext(context.Background()) +} + +func (o PipelineRestartWindowOutput) ToPipelineRestartWindowPtrOutputWithContext(ctx context.Context) PipelineRestartWindowPtrOutput { + return o.ApplyTWithContext(ctx, func(_ context.Context, v PipelineRestartWindow) *PipelineRestartWindow { + return &v + }).(PipelineRestartWindowPtrOutput) +} + +func (o PipelineRestartWindowOutput) DaysOfWeek() pulumi.StringPtrOutput { + return o.ApplyT(func(v PipelineRestartWindow) *string { return v.DaysOfWeek }).(pulumi.StringPtrOutput) +} + +func (o PipelineRestartWindowOutput) StartHour() pulumi.IntOutput { + return o.ApplyT(func(v PipelineRestartWindow) int { return v.StartHour }).(pulumi.IntOutput) +} + +func (o PipelineRestartWindowOutput) TimeZoneId() pulumi.StringPtrOutput { + return o.ApplyT(func(v PipelineRestartWindow) *string { return v.TimeZoneId }).(pulumi.StringPtrOutput) +} + +type PipelineRestartWindowPtrOutput struct{ *pulumi.OutputState } + +func (PipelineRestartWindowPtrOutput) ElementType() reflect.Type { + return reflect.TypeOf((**PipelineRestartWindow)(nil)).Elem() +} + +func (o PipelineRestartWindowPtrOutput) ToPipelineRestartWindowPtrOutput() PipelineRestartWindowPtrOutput { + return o +} + +func (o PipelineRestartWindowPtrOutput) ToPipelineRestartWindowPtrOutputWithContext(ctx context.Context) PipelineRestartWindowPtrOutput { + return o +} + +func (o PipelineRestartWindowPtrOutput) Elem() PipelineRestartWindowOutput { + return o.ApplyT(func(v *PipelineRestartWindow) PipelineRestartWindow { + if v != nil { + return *v + } + var ret PipelineRestartWindow + return ret + }).(PipelineRestartWindowOutput) +} + +func (o PipelineRestartWindowPtrOutput) DaysOfWeek() pulumi.StringPtrOutput { + return o.ApplyT(func(v *PipelineRestartWindow) *string { + if v == nil { + return nil + } + return v.DaysOfWeek + }).(pulumi.StringPtrOutput) +} + +func (o PipelineRestartWindowPtrOutput) StartHour() pulumi.IntPtrOutput { + return o.ApplyT(func(v *PipelineRestartWindow) *int { + if v == nil { + return nil + } + return &v.StartHour + }).(pulumi.IntPtrOutput) +} + +func (o PipelineRestartWindowPtrOutput) TimeZoneId() pulumi.StringPtrOutput { + return o.ApplyT(func(v *PipelineRestartWindow) *string { + if v == nil { + return nil + } + return v.TimeZoneId + }).(pulumi.StringPtrOutput) +} + type PipelineTrigger struct { Cron *PipelineTriggerCron `pulumi:"cron"` Manual *PipelineTriggerManual `pulumi:"manual"` @@ -83079,136 +83257,6 @@ func (o GetClusterClusterInfoGcpAttributesPtrOutput) ZoneId() pulumi.StringPtrOu }).(pulumi.StringPtrOutput) } -type GetClusterClusterInfoInitScript struct { - Abfss *GetClusterClusterInfoInitScriptAbfss `pulumi:"abfss"` - Dbfs *GetClusterClusterInfoInitScriptDbfs `pulumi:"dbfs"` - File *GetClusterClusterInfoInitScriptFile `pulumi:"file"` - Gcs *GetClusterClusterInfoInitScriptGcs `pulumi:"gcs"` - S3 *GetClusterClusterInfoInitScriptS3 `pulumi:"s3"` - Volumes *GetClusterClusterInfoInitScriptVolumes `pulumi:"volumes"` - Workspace *GetClusterClusterInfoInitScriptWorkspace `pulumi:"workspace"` -} - -// GetClusterClusterInfoInitScriptInput is an input type that accepts GetClusterClusterInfoInitScriptArgs and GetClusterClusterInfoInitScriptOutput values. -// You can construct a concrete instance of `GetClusterClusterInfoInitScriptInput` via: -// -// GetClusterClusterInfoInitScriptArgs{...} -type GetClusterClusterInfoInitScriptInput interface { - pulumi.Input - - ToGetClusterClusterInfoInitScriptOutput() GetClusterClusterInfoInitScriptOutput - ToGetClusterClusterInfoInitScriptOutputWithContext(context.Context) GetClusterClusterInfoInitScriptOutput -} - -type GetClusterClusterInfoInitScriptArgs struct { - Abfss GetClusterClusterInfoInitScriptAbfssPtrInput `pulumi:"abfss"` - Dbfs GetClusterClusterInfoInitScriptDbfsPtrInput `pulumi:"dbfs"` - File GetClusterClusterInfoInitScriptFilePtrInput `pulumi:"file"` - Gcs GetClusterClusterInfoInitScriptGcsPtrInput `pulumi:"gcs"` - S3 GetClusterClusterInfoInitScriptS3PtrInput `pulumi:"s3"` - Volumes GetClusterClusterInfoInitScriptVolumesPtrInput `pulumi:"volumes"` - Workspace GetClusterClusterInfoInitScriptWorkspacePtrInput `pulumi:"workspace"` -} - -func (GetClusterClusterInfoInitScriptArgs) ElementType() reflect.Type { - return reflect.TypeOf((*GetClusterClusterInfoInitScript)(nil)).Elem() -} - -func (i GetClusterClusterInfoInitScriptArgs) ToGetClusterClusterInfoInitScriptOutput() GetClusterClusterInfoInitScriptOutput { - return i.ToGetClusterClusterInfoInitScriptOutputWithContext(context.Background()) -} - -func (i GetClusterClusterInfoInitScriptArgs) ToGetClusterClusterInfoInitScriptOutputWithContext(ctx context.Context) GetClusterClusterInfoInitScriptOutput { - return pulumi.ToOutputWithContext(ctx, i).(GetClusterClusterInfoInitScriptOutput) -} - -// GetClusterClusterInfoInitScriptArrayInput is an input type that accepts GetClusterClusterInfoInitScriptArray and GetClusterClusterInfoInitScriptArrayOutput values. -// You can construct a concrete instance of `GetClusterClusterInfoInitScriptArrayInput` via: -// -// GetClusterClusterInfoInitScriptArray{ GetClusterClusterInfoInitScriptArgs{...} } -type GetClusterClusterInfoInitScriptArrayInput interface { - pulumi.Input - - ToGetClusterClusterInfoInitScriptArrayOutput() GetClusterClusterInfoInitScriptArrayOutput - ToGetClusterClusterInfoInitScriptArrayOutputWithContext(context.Context) GetClusterClusterInfoInitScriptArrayOutput -} - -type GetClusterClusterInfoInitScriptArray []GetClusterClusterInfoInitScriptInput - -func (GetClusterClusterInfoInitScriptArray) ElementType() reflect.Type { - return reflect.TypeOf((*[]GetClusterClusterInfoInitScript)(nil)).Elem() -} - -func (i GetClusterClusterInfoInitScriptArray) ToGetClusterClusterInfoInitScriptArrayOutput() GetClusterClusterInfoInitScriptArrayOutput { - return i.ToGetClusterClusterInfoInitScriptArrayOutputWithContext(context.Background()) -} - -func (i GetClusterClusterInfoInitScriptArray) ToGetClusterClusterInfoInitScriptArrayOutputWithContext(ctx context.Context) GetClusterClusterInfoInitScriptArrayOutput { - return pulumi.ToOutputWithContext(ctx, i).(GetClusterClusterInfoInitScriptArrayOutput) -} - -type GetClusterClusterInfoInitScriptOutput struct{ *pulumi.OutputState } - -func (GetClusterClusterInfoInitScriptOutput) ElementType() reflect.Type { - return reflect.TypeOf((*GetClusterClusterInfoInitScript)(nil)).Elem() -} - -func (o GetClusterClusterInfoInitScriptOutput) ToGetClusterClusterInfoInitScriptOutput() GetClusterClusterInfoInitScriptOutput { - return o -} - -func (o GetClusterClusterInfoInitScriptOutput) ToGetClusterClusterInfoInitScriptOutputWithContext(ctx context.Context) GetClusterClusterInfoInitScriptOutput { - return o -} - -func (o GetClusterClusterInfoInitScriptOutput) Abfss() GetClusterClusterInfoInitScriptAbfssPtrOutput { - return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptAbfss { return v.Abfss }).(GetClusterClusterInfoInitScriptAbfssPtrOutput) -} - -func (o GetClusterClusterInfoInitScriptOutput) Dbfs() GetClusterClusterInfoInitScriptDbfsPtrOutput { - return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptDbfs { return v.Dbfs }).(GetClusterClusterInfoInitScriptDbfsPtrOutput) -} - -func (o GetClusterClusterInfoInitScriptOutput) File() GetClusterClusterInfoInitScriptFilePtrOutput { - return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptFile { return v.File }).(GetClusterClusterInfoInitScriptFilePtrOutput) -} - -func (o GetClusterClusterInfoInitScriptOutput) Gcs() GetClusterClusterInfoInitScriptGcsPtrOutput { - return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptGcs { return v.Gcs }).(GetClusterClusterInfoInitScriptGcsPtrOutput) -} - -func (o GetClusterClusterInfoInitScriptOutput) S3() GetClusterClusterInfoInitScriptS3PtrOutput { - return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptS3 { return v.S3 }).(GetClusterClusterInfoInitScriptS3PtrOutput) -} - -func (o GetClusterClusterInfoInitScriptOutput) Volumes() GetClusterClusterInfoInitScriptVolumesPtrOutput { - return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptVolumes { return v.Volumes }).(GetClusterClusterInfoInitScriptVolumesPtrOutput) -} - -func (o GetClusterClusterInfoInitScriptOutput) Workspace() GetClusterClusterInfoInitScriptWorkspacePtrOutput { - return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptWorkspace { return v.Workspace }).(GetClusterClusterInfoInitScriptWorkspacePtrOutput) -} - -type GetClusterClusterInfoInitScriptArrayOutput struct{ *pulumi.OutputState } - -func (GetClusterClusterInfoInitScriptArrayOutput) ElementType() reflect.Type { - return reflect.TypeOf((*[]GetClusterClusterInfoInitScript)(nil)).Elem() -} - -func (o GetClusterClusterInfoInitScriptArrayOutput) ToGetClusterClusterInfoInitScriptArrayOutput() GetClusterClusterInfoInitScriptArrayOutput { - return o -} - -func (o GetClusterClusterInfoInitScriptArrayOutput) ToGetClusterClusterInfoInitScriptArrayOutputWithContext(ctx context.Context) GetClusterClusterInfoInitScriptArrayOutput { - return o -} - -func (o GetClusterClusterInfoInitScriptArrayOutput) Index(i pulumi.IntInput) GetClusterClusterInfoInitScriptOutput { - return pulumi.All(o, i).ApplyT(func(vs []interface{}) GetClusterClusterInfoInitScript { - return vs[0].([]GetClusterClusterInfoInitScript)[vs[1].(int)] - }).(GetClusterClusterInfoInitScriptOutput) -} - func init() { pulumi.RegisterInputType(reflect.TypeOf((*AccessControlRuleSetGrantRuleInput)(nil)).Elem(), AccessControlRuleSetGrantRuleArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*AccessControlRuleSetGrantRuleArrayInput)(nil)).Elem(), AccessControlRuleSetGrantRuleArray{}) @@ -84010,6 +84058,8 @@ func init() { pulumi.RegisterInputType(reflect.TypeOf((*PipelineLibraryNotebookPtrInput)(nil)).Elem(), PipelineLibraryNotebookArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*PipelineNotificationInput)(nil)).Elem(), PipelineNotificationArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*PipelineNotificationArrayInput)(nil)).Elem(), PipelineNotificationArray{}) + pulumi.RegisterInputType(reflect.TypeOf((*PipelineRestartWindowInput)(nil)).Elem(), PipelineRestartWindowArgs{}) + pulumi.RegisterInputType(reflect.TypeOf((*PipelineRestartWindowPtrInput)(nil)).Elem(), PipelineRestartWindowArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*PipelineTriggerInput)(nil)).Elem(), PipelineTriggerArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*PipelineTriggerPtrInput)(nil)).Elem(), PipelineTriggerArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*PipelineTriggerCronInput)(nil)).Elem(), PipelineTriggerCronArgs{}) @@ -84202,8 +84252,6 @@ func init() { pulumi.RegisterInputType(reflect.TypeOf((*GetClusterClusterInfoExecutorNodeAwsAttributesPtrInput)(nil)).Elem(), GetClusterClusterInfoExecutorNodeAwsAttributesArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*GetClusterClusterInfoGcpAttributesInput)(nil)).Elem(), GetClusterClusterInfoGcpAttributesArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*GetClusterClusterInfoGcpAttributesPtrInput)(nil)).Elem(), GetClusterClusterInfoGcpAttributesArgs{}) - pulumi.RegisterInputType(reflect.TypeOf((*GetClusterClusterInfoInitScriptInput)(nil)).Elem(), GetClusterClusterInfoInitScriptArgs{}) - pulumi.RegisterInputType(reflect.TypeOf((*GetClusterClusterInfoInitScriptArrayInput)(nil)).Elem(), GetClusterClusterInfoInitScriptArray{}) pulumi.RegisterOutputType(AccessControlRuleSetGrantRuleOutput{}) pulumi.RegisterOutputType(AccessControlRuleSetGrantRuleArrayOutput{}) pulumi.RegisterOutputType(AlertConditionOutput{}) @@ -85004,6 +85052,8 @@ func init() { pulumi.RegisterOutputType(PipelineLibraryNotebookPtrOutput{}) pulumi.RegisterOutputType(PipelineNotificationOutput{}) pulumi.RegisterOutputType(PipelineNotificationArrayOutput{}) + pulumi.RegisterOutputType(PipelineRestartWindowOutput{}) + pulumi.RegisterOutputType(PipelineRestartWindowPtrOutput{}) pulumi.RegisterOutputType(PipelineTriggerOutput{}) pulumi.RegisterOutputType(PipelineTriggerPtrOutput{}) pulumi.RegisterOutputType(PipelineTriggerCronOutput{}) @@ -85196,6 +85246,4 @@ func init() { pulumi.RegisterOutputType(GetClusterClusterInfoExecutorNodeAwsAttributesPtrOutput{}) pulumi.RegisterOutputType(GetClusterClusterInfoGcpAttributesOutput{}) pulumi.RegisterOutputType(GetClusterClusterInfoGcpAttributesPtrOutput{}) - pulumi.RegisterOutputType(GetClusterClusterInfoInitScriptOutput{}) - pulumi.RegisterOutputType(GetClusterClusterInfoInitScriptArrayOutput{}) } diff --git a/sdk/go/databricks/pulumiTypes1.go b/sdk/go/databricks/pulumiTypes1.go index 431e340f..e9a4027a 100644 --- a/sdk/go/databricks/pulumiTypes1.go +++ b/sdk/go/databricks/pulumiTypes1.go @@ -13,6 +13,136 @@ import ( var _ = internal.GetEnvOrDefault +type GetClusterClusterInfoInitScript struct { + Abfss *GetClusterClusterInfoInitScriptAbfss `pulumi:"abfss"` + Dbfs *GetClusterClusterInfoInitScriptDbfs `pulumi:"dbfs"` + File *GetClusterClusterInfoInitScriptFile `pulumi:"file"` + Gcs *GetClusterClusterInfoInitScriptGcs `pulumi:"gcs"` + S3 *GetClusterClusterInfoInitScriptS3 `pulumi:"s3"` + Volumes *GetClusterClusterInfoInitScriptVolumes `pulumi:"volumes"` + Workspace *GetClusterClusterInfoInitScriptWorkspace `pulumi:"workspace"` +} + +// GetClusterClusterInfoInitScriptInput is an input type that accepts GetClusterClusterInfoInitScriptArgs and GetClusterClusterInfoInitScriptOutput values. +// You can construct a concrete instance of `GetClusterClusterInfoInitScriptInput` via: +// +// GetClusterClusterInfoInitScriptArgs{...} +type GetClusterClusterInfoInitScriptInput interface { + pulumi.Input + + ToGetClusterClusterInfoInitScriptOutput() GetClusterClusterInfoInitScriptOutput + ToGetClusterClusterInfoInitScriptOutputWithContext(context.Context) GetClusterClusterInfoInitScriptOutput +} + +type GetClusterClusterInfoInitScriptArgs struct { + Abfss GetClusterClusterInfoInitScriptAbfssPtrInput `pulumi:"abfss"` + Dbfs GetClusterClusterInfoInitScriptDbfsPtrInput `pulumi:"dbfs"` + File GetClusterClusterInfoInitScriptFilePtrInput `pulumi:"file"` + Gcs GetClusterClusterInfoInitScriptGcsPtrInput `pulumi:"gcs"` + S3 GetClusterClusterInfoInitScriptS3PtrInput `pulumi:"s3"` + Volumes GetClusterClusterInfoInitScriptVolumesPtrInput `pulumi:"volumes"` + Workspace GetClusterClusterInfoInitScriptWorkspacePtrInput `pulumi:"workspace"` +} + +func (GetClusterClusterInfoInitScriptArgs) ElementType() reflect.Type { + return reflect.TypeOf((*GetClusterClusterInfoInitScript)(nil)).Elem() +} + +func (i GetClusterClusterInfoInitScriptArgs) ToGetClusterClusterInfoInitScriptOutput() GetClusterClusterInfoInitScriptOutput { + return i.ToGetClusterClusterInfoInitScriptOutputWithContext(context.Background()) +} + +func (i GetClusterClusterInfoInitScriptArgs) ToGetClusterClusterInfoInitScriptOutputWithContext(ctx context.Context) GetClusterClusterInfoInitScriptOutput { + return pulumi.ToOutputWithContext(ctx, i).(GetClusterClusterInfoInitScriptOutput) +} + +// GetClusterClusterInfoInitScriptArrayInput is an input type that accepts GetClusterClusterInfoInitScriptArray and GetClusterClusterInfoInitScriptArrayOutput values. +// You can construct a concrete instance of `GetClusterClusterInfoInitScriptArrayInput` via: +// +// GetClusterClusterInfoInitScriptArray{ GetClusterClusterInfoInitScriptArgs{...} } +type GetClusterClusterInfoInitScriptArrayInput interface { + pulumi.Input + + ToGetClusterClusterInfoInitScriptArrayOutput() GetClusterClusterInfoInitScriptArrayOutput + ToGetClusterClusterInfoInitScriptArrayOutputWithContext(context.Context) GetClusterClusterInfoInitScriptArrayOutput +} + +type GetClusterClusterInfoInitScriptArray []GetClusterClusterInfoInitScriptInput + +func (GetClusterClusterInfoInitScriptArray) ElementType() reflect.Type { + return reflect.TypeOf((*[]GetClusterClusterInfoInitScript)(nil)).Elem() +} + +func (i GetClusterClusterInfoInitScriptArray) ToGetClusterClusterInfoInitScriptArrayOutput() GetClusterClusterInfoInitScriptArrayOutput { + return i.ToGetClusterClusterInfoInitScriptArrayOutputWithContext(context.Background()) +} + +func (i GetClusterClusterInfoInitScriptArray) ToGetClusterClusterInfoInitScriptArrayOutputWithContext(ctx context.Context) GetClusterClusterInfoInitScriptArrayOutput { + return pulumi.ToOutputWithContext(ctx, i).(GetClusterClusterInfoInitScriptArrayOutput) +} + +type GetClusterClusterInfoInitScriptOutput struct{ *pulumi.OutputState } + +func (GetClusterClusterInfoInitScriptOutput) ElementType() reflect.Type { + return reflect.TypeOf((*GetClusterClusterInfoInitScript)(nil)).Elem() +} + +func (o GetClusterClusterInfoInitScriptOutput) ToGetClusterClusterInfoInitScriptOutput() GetClusterClusterInfoInitScriptOutput { + return o +} + +func (o GetClusterClusterInfoInitScriptOutput) ToGetClusterClusterInfoInitScriptOutputWithContext(ctx context.Context) GetClusterClusterInfoInitScriptOutput { + return o +} + +func (o GetClusterClusterInfoInitScriptOutput) Abfss() GetClusterClusterInfoInitScriptAbfssPtrOutput { + return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptAbfss { return v.Abfss }).(GetClusterClusterInfoInitScriptAbfssPtrOutput) +} + +func (o GetClusterClusterInfoInitScriptOutput) Dbfs() GetClusterClusterInfoInitScriptDbfsPtrOutput { + return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptDbfs { return v.Dbfs }).(GetClusterClusterInfoInitScriptDbfsPtrOutput) +} + +func (o GetClusterClusterInfoInitScriptOutput) File() GetClusterClusterInfoInitScriptFilePtrOutput { + return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptFile { return v.File }).(GetClusterClusterInfoInitScriptFilePtrOutput) +} + +func (o GetClusterClusterInfoInitScriptOutput) Gcs() GetClusterClusterInfoInitScriptGcsPtrOutput { + return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptGcs { return v.Gcs }).(GetClusterClusterInfoInitScriptGcsPtrOutput) +} + +func (o GetClusterClusterInfoInitScriptOutput) S3() GetClusterClusterInfoInitScriptS3PtrOutput { + return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptS3 { return v.S3 }).(GetClusterClusterInfoInitScriptS3PtrOutput) +} + +func (o GetClusterClusterInfoInitScriptOutput) Volumes() GetClusterClusterInfoInitScriptVolumesPtrOutput { + return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptVolumes { return v.Volumes }).(GetClusterClusterInfoInitScriptVolumesPtrOutput) +} + +func (o GetClusterClusterInfoInitScriptOutput) Workspace() GetClusterClusterInfoInitScriptWorkspacePtrOutput { + return o.ApplyT(func(v GetClusterClusterInfoInitScript) *GetClusterClusterInfoInitScriptWorkspace { return v.Workspace }).(GetClusterClusterInfoInitScriptWorkspacePtrOutput) +} + +type GetClusterClusterInfoInitScriptArrayOutput struct{ *pulumi.OutputState } + +func (GetClusterClusterInfoInitScriptArrayOutput) ElementType() reflect.Type { + return reflect.TypeOf((*[]GetClusterClusterInfoInitScript)(nil)).Elem() +} + +func (o GetClusterClusterInfoInitScriptArrayOutput) ToGetClusterClusterInfoInitScriptArrayOutput() GetClusterClusterInfoInitScriptArrayOutput { + return o +} + +func (o GetClusterClusterInfoInitScriptArrayOutput) ToGetClusterClusterInfoInitScriptArrayOutputWithContext(ctx context.Context) GetClusterClusterInfoInitScriptArrayOutput { + return o +} + +func (o GetClusterClusterInfoInitScriptArrayOutput) Index(i pulumi.IntInput) GetClusterClusterInfoInitScriptOutput { + return pulumi.All(o, i).ApplyT(func(vs []interface{}) GetClusterClusterInfoInitScript { + return vs[0].([]GetClusterClusterInfoInitScript)[vs[1].(int)] + }).(GetClusterClusterInfoInitScriptOutput) +} + type GetClusterClusterInfoInitScriptAbfss struct { Destination string `pulumi:"destination"` } @@ -45926,6 +46056,7 @@ type GetStorageCredentialStorageCredentialInfo struct { CreatedBy *string `pulumi:"createdBy"` // credential details for GCP: DatabricksGcpServiceAccount *GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccount `pulumi:"databricksGcpServiceAccount"` + FullName *string `pulumi:"fullName"` // Unique ID of storage credential. Id *string `pulumi:"id"` IsolationMode *string `pulumi:"isolationMode"` @@ -45970,6 +46101,7 @@ type GetStorageCredentialStorageCredentialInfoArgs struct { CreatedBy pulumi.StringPtrInput `pulumi:"createdBy"` // credential details for GCP: DatabricksGcpServiceAccount GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccountPtrInput `pulumi:"databricksGcpServiceAccount"` + FullName pulumi.StringPtrInput `pulumi:"fullName"` // Unique ID of storage credential. Id pulumi.StringPtrInput `pulumi:"id"` IsolationMode pulumi.StringPtrInput `pulumi:"isolationMode"` @@ -46113,6 +46245,10 @@ func (o GetStorageCredentialStorageCredentialInfoOutput) DatabricksGcpServiceAcc }).(GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccountPtrOutput) } +func (o GetStorageCredentialStorageCredentialInfoOutput) FullName() pulumi.StringPtrOutput { + return o.ApplyT(func(v GetStorageCredentialStorageCredentialInfo) *string { return v.FullName }).(pulumi.StringPtrOutput) +} + // Unique ID of storage credential. func (o GetStorageCredentialStorageCredentialInfoOutput) Id() pulumi.StringPtrOutput { return o.ApplyT(func(v GetStorageCredentialStorageCredentialInfo) *string { return v.Id }).(pulumi.StringPtrOutput) @@ -46258,6 +46394,15 @@ func (o GetStorageCredentialStorageCredentialInfoPtrOutput) DatabricksGcpService }).(GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccountPtrOutput) } +func (o GetStorageCredentialStorageCredentialInfoPtrOutput) FullName() pulumi.StringPtrOutput { + return o.ApplyT(func(v *GetStorageCredentialStorageCredentialInfo) *string { + if v == nil { + return nil + } + return v.FullName + }).(pulumi.StringPtrOutput) +} + // Unique ID of storage credential. func (o GetStorageCredentialStorageCredentialInfoPtrOutput) Id() pulumi.StringPtrOutput { return o.ApplyT(func(v *GetStorageCredentialStorageCredentialInfo) *string { @@ -50682,6 +50827,8 @@ func (o GetVolumeVolumeInfoEncryptionDetailsSseEncryptionDetailsPtrOutput) AwsKm } func init() { + pulumi.RegisterInputType(reflect.TypeOf((*GetClusterClusterInfoInitScriptInput)(nil)).Elem(), GetClusterClusterInfoInitScriptArgs{}) + pulumi.RegisterInputType(reflect.TypeOf((*GetClusterClusterInfoInitScriptArrayInput)(nil)).Elem(), GetClusterClusterInfoInitScriptArray{}) pulumi.RegisterInputType(reflect.TypeOf((*GetClusterClusterInfoInitScriptAbfssInput)(nil)).Elem(), GetClusterClusterInfoInitScriptAbfssArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*GetClusterClusterInfoInitScriptAbfssPtrInput)(nil)).Elem(), GetClusterClusterInfoInitScriptAbfssArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*GetClusterClusterInfoInitScriptDbfsInput)(nil)).Elem(), GetClusterClusterInfoInitScriptDbfsArgs{}) @@ -51282,6 +51429,8 @@ func init() { pulumi.RegisterInputType(reflect.TypeOf((*GetVolumeVolumeInfoEncryptionDetailsPtrInput)(nil)).Elem(), GetVolumeVolumeInfoEncryptionDetailsArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*GetVolumeVolumeInfoEncryptionDetailsSseEncryptionDetailsInput)(nil)).Elem(), GetVolumeVolumeInfoEncryptionDetailsSseEncryptionDetailsArgs{}) pulumi.RegisterInputType(reflect.TypeOf((*GetVolumeVolumeInfoEncryptionDetailsSseEncryptionDetailsPtrInput)(nil)).Elem(), GetVolumeVolumeInfoEncryptionDetailsSseEncryptionDetailsArgs{}) + pulumi.RegisterOutputType(GetClusterClusterInfoInitScriptOutput{}) + pulumi.RegisterOutputType(GetClusterClusterInfoInitScriptArrayOutput{}) pulumi.RegisterOutputType(GetClusterClusterInfoInitScriptAbfssOutput{}) pulumi.RegisterOutputType(GetClusterClusterInfoInitScriptAbfssPtrOutput{}) pulumi.RegisterOutputType(GetClusterClusterInfoInitScriptDbfsOutput{}) diff --git a/sdk/java/src/main/java/com/pulumi/databricks/Pipeline.java b/sdk/java/src/main/java/com/pulumi/databricks/Pipeline.java index ebcb2f8b..ea10180f 100644 --- a/sdk/java/src/main/java/com/pulumi/databricks/Pipeline.java +++ b/sdk/java/src/main/java/com/pulumi/databricks/Pipeline.java @@ -18,6 +18,7 @@ import com.pulumi.databricks.outputs.PipelineLatestUpdate; import com.pulumi.databricks.outputs.PipelineLibrary; import com.pulumi.databricks.outputs.PipelineNotification; +import com.pulumi.databricks.outputs.PipelineRestartWindow; import com.pulumi.databricks.outputs.PipelineTrigger; import java.lang.Boolean; import java.lang.Integer; @@ -401,6 +402,12 @@ public Output>> notifications() { public Output> photon() { return Codegen.optional(this.photon); } + @Export(name="restartWindow", refs={PipelineRestartWindow.class}, tree="[0]") + private Output restartWindow; + + public Output> restartWindow() { + return Codegen.optional(this.restartWindow); + } @Export(name="runAsUserName", refs={String.class}, tree="[0]") private Output runAsUserName; diff --git a/sdk/java/src/main/java/com/pulumi/databricks/PipelineArgs.java b/sdk/java/src/main/java/com/pulumi/databricks/PipelineArgs.java index 3ed6c90b..8121b3c7 100644 --- a/sdk/java/src/main/java/com/pulumi/databricks/PipelineArgs.java +++ b/sdk/java/src/main/java/com/pulumi/databricks/PipelineArgs.java @@ -13,6 +13,7 @@ import com.pulumi.databricks.inputs.PipelineLatestUpdateArgs; import com.pulumi.databricks.inputs.PipelineLibraryArgs; import com.pulumi.databricks.inputs.PipelineNotificationArgs; +import com.pulumi.databricks.inputs.PipelineRestartWindowArgs; import com.pulumi.databricks.inputs.PipelineTriggerArgs; import java.lang.Boolean; import java.lang.Integer; @@ -316,6 +317,13 @@ public Optional> photon() { return Optional.ofNullable(this.photon); } + @Import(name="restartWindow") + private @Nullable Output restartWindow; + + public Optional> restartWindow() { + return Optional.ofNullable(this.restartWindow); + } + @Import(name="runAsUserName") private @Nullable Output runAsUserName; @@ -439,6 +447,7 @@ private PipelineArgs(PipelineArgs $) { this.name = $.name; this.notifications = $.notifications; this.photon = $.photon; + this.restartWindow = $.restartWindow; this.runAsUserName = $.runAsUserName; this.schema = $.schema; this.serverless = $.serverless; @@ -891,6 +900,15 @@ public Builder photon(Boolean photon) { return photon(Output.of(photon)); } + public Builder restartWindow(@Nullable Output restartWindow) { + $.restartWindow = restartWindow; + return this; + } + + public Builder restartWindow(PipelineRestartWindowArgs restartWindow) { + return restartWindow(Output.of(restartWindow)); + } + public Builder runAsUserName(@Nullable Output runAsUserName) { $.runAsUserName = runAsUserName; return this; diff --git a/sdk/java/src/main/java/com/pulumi/databricks/inputs/GetStorageCredentialStorageCredentialInfo.java b/sdk/java/src/main/java/com/pulumi/databricks/inputs/GetStorageCredentialStorageCredentialInfo.java index f67a1b35..a59efa39 100644 --- a/sdk/java/src/main/java/com/pulumi/databricks/inputs/GetStorageCredentialStorageCredentialInfo.java +++ b/sdk/java/src/main/java/com/pulumi/databricks/inputs/GetStorageCredentialStorageCredentialInfo.java @@ -125,6 +125,13 @@ public Optional fullName() { + return Optional.ofNullable(this.fullName); + } + /** * Unique ID of storage credential. * @@ -255,6 +262,7 @@ private GetStorageCredentialStorageCredentialInfo(GetStorageCredentialStorageCre this.createdAt = $.createdAt; this.createdBy = $.createdBy; this.databricksGcpServiceAccount = $.databricksGcpServiceAccount; + this.fullName = $.fullName; this.id = $.id; this.isolationMode = $.isolationMode; this.metastoreId = $.metastoreId; @@ -360,6 +368,11 @@ public Builder databricksGcpServiceAccount(@Nullable GetStorageCredentialStorage return this; } + public Builder fullName(@Nullable String fullName) { + $.fullName = fullName; + return this; + } + /** * @param id Unique ID of storage credential. * diff --git a/sdk/java/src/main/java/com/pulumi/databricks/inputs/GetStorageCredentialStorageCredentialInfoArgs.java b/sdk/java/src/main/java/com/pulumi/databricks/inputs/GetStorageCredentialStorageCredentialInfoArgs.java index f6736c89..fc0d0a02 100644 --- a/sdk/java/src/main/java/com/pulumi/databricks/inputs/GetStorageCredentialStorageCredentialInfoArgs.java +++ b/sdk/java/src/main/java/com/pulumi/databricks/inputs/GetStorageCredentialStorageCredentialInfoArgs.java @@ -126,6 +126,13 @@ public Optional fullName; + + public Optional> fullName() { + return Optional.ofNullable(this.fullName); + } + /** * Unique ID of storage credential. * @@ -256,6 +263,7 @@ private GetStorageCredentialStorageCredentialInfoArgs(GetStorageCredentialStorag this.createdAt = $.createdAt; this.createdBy = $.createdBy; this.databricksGcpServiceAccount = $.databricksGcpServiceAccount; + this.fullName = $.fullName; this.id = $.id; this.isolationMode = $.isolationMode; this.metastoreId = $.metastoreId; @@ -429,6 +437,15 @@ public Builder databricksGcpServiceAccount(GetStorageCredentialStorageCredential return databricksGcpServiceAccount(Output.of(databricksGcpServiceAccount)); } + public Builder fullName(@Nullable Output fullName) { + $.fullName = fullName; + return this; + } + + public Builder fullName(String fullName) { + return fullName(Output.of(fullName)); + } + /** * @param id Unique ID of storage credential. * diff --git a/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineGatewayDefinitionArgs.java b/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineGatewayDefinitionArgs.java index eb6c61d1..74738551 100644 --- a/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineGatewayDefinitionArgs.java +++ b/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineGatewayDefinitionArgs.java @@ -30,6 +30,13 @@ public Optional> connectionId() { return Optional.ofNullable(this.connectionId); } + @Import(name="connectionName") + private @Nullable Output connectionName; + + public Optional> connectionName() { + return Optional.ofNullable(this.connectionName); + } + /** * Required, Immutable. The name of the catalog for the gateway pipeline's storage location. * @@ -79,6 +86,7 @@ private PipelineGatewayDefinitionArgs() {} private PipelineGatewayDefinitionArgs(PipelineGatewayDefinitionArgs $) { this.connectionId = $.connectionId; + this.connectionName = $.connectionName; this.gatewayStorageCatalog = $.gatewayStorageCatalog; this.gatewayStorageName = $.gatewayStorageName; this.gatewayStorageSchema = $.gatewayStorageSchema; @@ -123,6 +131,15 @@ public Builder connectionId(String connectionId) { return connectionId(Output.of(connectionId)); } + public Builder connectionName(@Nullable Output connectionName) { + $.connectionName = connectionName; + return this; + } + + public Builder connectionName(String connectionName) { + return connectionName(Output.of(connectionName)); + } + /** * @param gatewayStorageCatalog Required, Immutable. The name of the catalog for the gateway pipeline's storage location. * diff --git a/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineRestartWindowArgs.java b/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineRestartWindowArgs.java new file mode 100644 index 00000000..8b760e4d --- /dev/null +++ b/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineRestartWindowArgs.java @@ -0,0 +1,102 @@ +// *** WARNING: this file was generated by pulumi-java-gen. *** +// *** Do not edit by hand unless you're certain you know what you are doing! *** + +package com.pulumi.databricks.inputs; + +import com.pulumi.core.Output; +import com.pulumi.core.annotations.Import; +import com.pulumi.exceptions.MissingRequiredPropertyException; +import java.lang.Integer; +import java.lang.String; +import java.util.Objects; +import java.util.Optional; +import javax.annotation.Nullable; + + +public final class PipelineRestartWindowArgs extends com.pulumi.resources.ResourceArgs { + + public static final PipelineRestartWindowArgs Empty = new PipelineRestartWindowArgs(); + + @Import(name="daysOfWeek") + private @Nullable Output daysOfWeek; + + public Optional> daysOfWeek() { + return Optional.ofNullable(this.daysOfWeek); + } + + @Import(name="startHour", required=true) + private Output startHour; + + public Output startHour() { + return this.startHour; + } + + @Import(name="timeZoneId") + private @Nullable Output timeZoneId; + + public Optional> timeZoneId() { + return Optional.ofNullable(this.timeZoneId); + } + + private PipelineRestartWindowArgs() {} + + private PipelineRestartWindowArgs(PipelineRestartWindowArgs $) { + this.daysOfWeek = $.daysOfWeek; + this.startHour = $.startHour; + this.timeZoneId = $.timeZoneId; + } + + public static Builder builder() { + return new Builder(); + } + public static Builder builder(PipelineRestartWindowArgs defaults) { + return new Builder(defaults); + } + + public static final class Builder { + private PipelineRestartWindowArgs $; + + public Builder() { + $ = new PipelineRestartWindowArgs(); + } + + public Builder(PipelineRestartWindowArgs defaults) { + $ = new PipelineRestartWindowArgs(Objects.requireNonNull(defaults)); + } + + public Builder daysOfWeek(@Nullable Output daysOfWeek) { + $.daysOfWeek = daysOfWeek; + return this; + } + + public Builder daysOfWeek(String daysOfWeek) { + return daysOfWeek(Output.of(daysOfWeek)); + } + + public Builder startHour(Output startHour) { + $.startHour = startHour; + return this; + } + + public Builder startHour(Integer startHour) { + return startHour(Output.of(startHour)); + } + + public Builder timeZoneId(@Nullable Output timeZoneId) { + $.timeZoneId = timeZoneId; + return this; + } + + public Builder timeZoneId(String timeZoneId) { + return timeZoneId(Output.of(timeZoneId)); + } + + public PipelineRestartWindowArgs build() { + if ($.startHour == null) { + throw new MissingRequiredPropertyException("PipelineRestartWindowArgs", "startHour"); + } + return $; + } + } + +} diff --git a/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineState.java b/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineState.java index 5508ef84..548f68f0 100644 --- a/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineState.java +++ b/sdk/java/src/main/java/com/pulumi/databricks/inputs/PipelineState.java @@ -13,6 +13,7 @@ import com.pulumi.databricks.inputs.PipelineLatestUpdateArgs; import com.pulumi.databricks.inputs.PipelineLibraryArgs; import com.pulumi.databricks.inputs.PipelineNotificationArgs; +import com.pulumi.databricks.inputs.PipelineRestartWindowArgs; import com.pulumi.databricks.inputs.PipelineTriggerArgs; import java.lang.Boolean; import java.lang.Integer; @@ -316,6 +317,13 @@ public Optional> photon() { return Optional.ofNullable(this.photon); } + @Import(name="restartWindow") + private @Nullable Output restartWindow; + + public Optional> restartWindow() { + return Optional.ofNullable(this.restartWindow); + } + @Import(name="runAsUserName") private @Nullable Output runAsUserName; @@ -439,6 +447,7 @@ private PipelineState(PipelineState $) { this.name = $.name; this.notifications = $.notifications; this.photon = $.photon; + this.restartWindow = $.restartWindow; this.runAsUserName = $.runAsUserName; this.schema = $.schema; this.serverless = $.serverless; @@ -891,6 +900,15 @@ public Builder photon(Boolean photon) { return photon(Output.of(photon)); } + public Builder restartWindow(@Nullable Output restartWindow) { + $.restartWindow = restartWindow; + return this; + } + + public Builder restartWindow(PipelineRestartWindowArgs restartWindow) { + return restartWindow(Output.of(restartWindow)); + } + public Builder runAsUserName(@Nullable Output runAsUserName) { $.runAsUserName = runAsUserName; return this; diff --git a/sdk/java/src/main/java/com/pulumi/databricks/outputs/GetStorageCredentialStorageCredentialInfo.java b/sdk/java/src/main/java/com/pulumi/databricks/outputs/GetStorageCredentialStorageCredentialInfo.java index 82d1b730..a224dd14 100644 --- a/sdk/java/src/main/java/com/pulumi/databricks/outputs/GetStorageCredentialStorageCredentialInfo.java +++ b/sdk/java/src/main/java/com/pulumi/databricks/outputs/GetStorageCredentialStorageCredentialInfo.java @@ -50,6 +50,7 @@ public final class GetStorageCredentialStorageCredentialInfo { * */ private @Nullable GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccount databricksGcpServiceAccount; + private @Nullable String fullName; /** * @return Unique ID of storage credential. * @@ -137,6 +138,9 @@ public Optional createdBy() { public Optional databricksGcpServiceAccount() { return Optional.ofNullable(this.databricksGcpServiceAccount); } + public Optional fullName() { + return Optional.ofNullable(this.fullName); + } /** * @return Unique ID of storage credential. * @@ -210,6 +214,7 @@ public static final class Builder { private @Nullable Integer createdAt; private @Nullable String createdBy; private @Nullable GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccount databricksGcpServiceAccount; + private @Nullable String fullName; private @Nullable String id; private @Nullable String isolationMode; private @Nullable String metastoreId; @@ -230,6 +235,7 @@ public Builder(GetStorageCredentialStorageCredentialInfo defaults) { this.createdAt = defaults.createdAt; this.createdBy = defaults.createdBy; this.databricksGcpServiceAccount = defaults.databricksGcpServiceAccount; + this.fullName = defaults.fullName; this.id = defaults.id; this.isolationMode = defaults.isolationMode; this.metastoreId = defaults.metastoreId; @@ -290,6 +296,12 @@ public Builder databricksGcpServiceAccount(@Nullable GetStorageCredentialStorage return this; } @CustomType.Setter + public Builder fullName(@Nullable String fullName) { + + this.fullName = fullName; + return this; + } + @CustomType.Setter public Builder id(@Nullable String id) { this.id = id; @@ -353,6 +365,7 @@ public GetStorageCredentialStorageCredentialInfo build() { _resultValue.createdAt = createdAt; _resultValue.createdBy = createdBy; _resultValue.databricksGcpServiceAccount = databricksGcpServiceAccount; + _resultValue.fullName = fullName; _resultValue.id = id; _resultValue.isolationMode = isolationMode; _resultValue.metastoreId = metastoreId; diff --git a/sdk/java/src/main/java/com/pulumi/databricks/outputs/PipelineGatewayDefinition.java b/sdk/java/src/main/java/com/pulumi/databricks/outputs/PipelineGatewayDefinition.java index ce79633b..9c0a1459 100644 --- a/sdk/java/src/main/java/com/pulumi/databricks/outputs/PipelineGatewayDefinition.java +++ b/sdk/java/src/main/java/com/pulumi/databricks/outputs/PipelineGatewayDefinition.java @@ -16,6 +16,7 @@ public final class PipelineGatewayDefinition { * */ private @Nullable String connectionId; + private @Nullable String connectionName; /** * @return Required, Immutable. The name of the catalog for the gateway pipeline's storage location. * @@ -40,6 +41,9 @@ private PipelineGatewayDefinition() {} public Optional connectionId() { return Optional.ofNullable(this.connectionId); } + public Optional connectionName() { + return Optional.ofNullable(this.connectionName); + } /** * @return Required, Immutable. The name of the catalog for the gateway pipeline's storage location. * @@ -72,6 +76,7 @@ public static Builder builder(PipelineGatewayDefinition defaults) { @CustomType.Builder public static final class Builder { private @Nullable String connectionId; + private @Nullable String connectionName; private @Nullable String gatewayStorageCatalog; private @Nullable String gatewayStorageName; private @Nullable String gatewayStorageSchema; @@ -79,6 +84,7 @@ public Builder() {} public Builder(PipelineGatewayDefinition defaults) { Objects.requireNonNull(defaults); this.connectionId = defaults.connectionId; + this.connectionName = defaults.connectionName; this.gatewayStorageCatalog = defaults.gatewayStorageCatalog; this.gatewayStorageName = defaults.gatewayStorageName; this.gatewayStorageSchema = defaults.gatewayStorageSchema; @@ -91,6 +97,12 @@ public Builder connectionId(@Nullable String connectionId) { return this; } @CustomType.Setter + public Builder connectionName(@Nullable String connectionName) { + + this.connectionName = connectionName; + return this; + } + @CustomType.Setter public Builder gatewayStorageCatalog(@Nullable String gatewayStorageCatalog) { this.gatewayStorageCatalog = gatewayStorageCatalog; @@ -111,6 +123,7 @@ public Builder gatewayStorageSchema(@Nullable String gatewayStorageSchema) { public PipelineGatewayDefinition build() { final var _resultValue = new PipelineGatewayDefinition(); _resultValue.connectionId = connectionId; + _resultValue.connectionName = connectionName; _resultValue.gatewayStorageCatalog = gatewayStorageCatalog; _resultValue.gatewayStorageName = gatewayStorageName; _resultValue.gatewayStorageSchema = gatewayStorageSchema; diff --git a/sdk/java/src/main/java/com/pulumi/databricks/outputs/PipelineRestartWindow.java b/sdk/java/src/main/java/com/pulumi/databricks/outputs/PipelineRestartWindow.java new file mode 100644 index 00000000..dddc0d30 --- /dev/null +++ b/sdk/java/src/main/java/com/pulumi/databricks/outputs/PipelineRestartWindow.java @@ -0,0 +1,79 @@ +// *** WARNING: this file was generated by pulumi-java-gen. *** +// *** Do not edit by hand unless you're certain you know what you are doing! *** + +package com.pulumi.databricks.outputs; + +import com.pulumi.core.annotations.CustomType; +import com.pulumi.exceptions.MissingRequiredPropertyException; +import java.lang.Integer; +import java.lang.String; +import java.util.Objects; +import java.util.Optional; +import javax.annotation.Nullable; + +@CustomType +public final class PipelineRestartWindow { + private @Nullable String daysOfWeek; + private Integer startHour; + private @Nullable String timeZoneId; + + private PipelineRestartWindow() {} + public Optional daysOfWeek() { + return Optional.ofNullable(this.daysOfWeek); + } + public Integer startHour() { + return this.startHour; + } + public Optional timeZoneId() { + return Optional.ofNullable(this.timeZoneId); + } + + public static Builder builder() { + return new Builder(); + } + + public static Builder builder(PipelineRestartWindow defaults) { + return new Builder(defaults); + } + @CustomType.Builder + public static final class Builder { + private @Nullable String daysOfWeek; + private Integer startHour; + private @Nullable String timeZoneId; + public Builder() {} + public Builder(PipelineRestartWindow defaults) { + Objects.requireNonNull(defaults); + this.daysOfWeek = defaults.daysOfWeek; + this.startHour = defaults.startHour; + this.timeZoneId = defaults.timeZoneId; + } + + @CustomType.Setter + public Builder daysOfWeek(@Nullable String daysOfWeek) { + + this.daysOfWeek = daysOfWeek; + return this; + } + @CustomType.Setter + public Builder startHour(Integer startHour) { + if (startHour == null) { + throw new MissingRequiredPropertyException("PipelineRestartWindow", "startHour"); + } + this.startHour = startHour; + return this; + } + @CustomType.Setter + public Builder timeZoneId(@Nullable String timeZoneId) { + + this.timeZoneId = timeZoneId; + return this; + } + public PipelineRestartWindow build() { + final var _resultValue = new PipelineRestartWindow(); + _resultValue.daysOfWeek = daysOfWeek; + _resultValue.startHour = startHour; + _resultValue.timeZoneId = timeZoneId; + return _resultValue; + } + } +} diff --git a/sdk/nodejs/pipeline.ts b/sdk/nodejs/pipeline.ts index 0465c4c6..4a22c74c 100644 --- a/sdk/nodejs/pipeline.ts +++ b/sdk/nodejs/pipeline.ts @@ -185,6 +185,7 @@ export class Pipeline extends pulumi.CustomResource { * A flag indicating whether to use Photon engine. The default value is `false`. */ public readonly photon!: pulumi.Output; + public readonly restartWindow!: pulumi.Output; public readonly runAsUserName!: pulumi.Output; /** * The default schema (database) where tables are read from or published to. The presence of this attribute implies that the pipeline is in direct publishing mode. @@ -246,6 +247,7 @@ export class Pipeline extends pulumi.CustomResource { resourceInputs["name"] = state ? state.name : undefined; resourceInputs["notifications"] = state ? state.notifications : undefined; resourceInputs["photon"] = state ? state.photon : undefined; + resourceInputs["restartWindow"] = state ? state.restartWindow : undefined; resourceInputs["runAsUserName"] = state ? state.runAsUserName : undefined; resourceInputs["schema"] = state ? state.schema : undefined; resourceInputs["serverless"] = state ? state.serverless : undefined; @@ -280,6 +282,7 @@ export class Pipeline extends pulumi.CustomResource { resourceInputs["name"] = args ? args.name : undefined; resourceInputs["notifications"] = args ? args.notifications : undefined; resourceInputs["photon"] = args ? args.photon : undefined; + resourceInputs["restartWindow"] = args ? args.restartWindow : undefined; resourceInputs["runAsUserName"] = args ? args.runAsUserName : undefined; resourceInputs["schema"] = args ? args.schema : undefined; resourceInputs["serverless"] = args ? args.serverless : undefined; @@ -367,6 +370,7 @@ export interface PipelineState { * A flag indicating whether to use Photon engine. The default value is `false`. */ photon?: pulumi.Input; + restartWindow?: pulumi.Input; runAsUserName?: pulumi.Input; /** * The default schema (database) where tables are read from or published to. The presence of this attribute implies that the pipeline is in direct publishing mode. @@ -465,6 +469,7 @@ export interface PipelineArgs { * A flag indicating whether to use Photon engine. The default value is `false`. */ photon?: pulumi.Input; + restartWindow?: pulumi.Input; runAsUserName?: pulumi.Input; /** * The default schema (database) where tables are read from or published to. The presence of this attribute implies that the pipeline is in direct publishing mode. diff --git a/sdk/nodejs/types/input.ts b/sdk/nodejs/types/input.ts index 16de619c..3a28c5b6 100644 --- a/sdk/nodejs/types/input.ts +++ b/sdk/nodejs/types/input.ts @@ -6352,6 +6352,7 @@ export interface GetStorageCredentialStorageCredentialInfo { * credential details for GCP: */ databricksGcpServiceAccount?: inputs.GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccount; + fullName?: string; /** * Unique ID of storage credential. */ @@ -6411,6 +6412,7 @@ export interface GetStorageCredentialStorageCredentialInfoArgs { * credential details for GCP: */ databricksGcpServiceAccount?: pulumi.Input; + fullName?: pulumi.Input; /** * Unique ID of storage credential. */ @@ -10857,6 +10859,7 @@ export interface PipelineGatewayDefinition { * Immutable. The Unity Catalog connection this gateway pipeline uses to communicate with the source. */ connectionId?: pulumi.Input; + connectionName?: pulumi.Input; /** * Required, Immutable. The name of the catalog for the gateway pipeline's storage location. */ @@ -10987,6 +10990,12 @@ export interface PipelineNotification { emailRecipients?: pulumi.Input[]>; } +export interface PipelineRestartWindow { + daysOfWeek?: pulumi.Input; + startHour: pulumi.Input; + timeZoneId?: pulumi.Input; +} + export interface PipelineTrigger { cron?: pulumi.Input; manual?: pulumi.Input; diff --git a/sdk/nodejs/types/output.ts b/sdk/nodejs/types/output.ts index 6bf7d1b2..3ad52f5f 100644 --- a/sdk/nodejs/types/output.ts +++ b/sdk/nodejs/types/output.ts @@ -3534,6 +3534,7 @@ export interface GetStorageCredentialStorageCredentialInfo { * credential details for GCP: */ databricksGcpServiceAccount?: outputs.GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccount; + fullName?: string; /** * Unique ID of storage credential. */ @@ -7684,6 +7685,7 @@ export interface PipelineGatewayDefinition { * Immutable. The Unity Catalog connection this gateway pipeline uses to communicate with the source. */ connectionId?: string; + connectionName?: string; /** * Required, Immutable. The name of the catalog for the gateway pipeline's storage location. */ @@ -7814,6 +7816,12 @@ export interface PipelineNotification { emailRecipients?: string[]; } +export interface PipelineRestartWindow { + daysOfWeek?: string; + startHour: number; + timeZoneId?: string; +} + export interface PipelineTrigger { cron?: outputs.PipelineTriggerCron; manual?: outputs.PipelineTriggerManual; diff --git a/sdk/python/pulumi_databricks/_inputs.py b/sdk/python/pulumi_databricks/_inputs.py index 0a98b246..781cb4c2 100644 --- a/sdk/python/pulumi_databricks/_inputs.py +++ b/sdk/python/pulumi_databricks/_inputs.py @@ -821,6 +821,8 @@ 'PipelineLibraryNotebookArgsDict', 'PipelineNotificationArgs', 'PipelineNotificationArgsDict', + 'PipelineRestartWindowArgs', + 'PipelineRestartWindowArgsDict', 'PipelineTriggerArgs', 'PipelineTriggerArgsDict', 'PipelineTriggerCronArgs', @@ -27844,6 +27846,7 @@ class PipelineGatewayDefinitionArgsDict(TypedDict): """ Immutable. The Unity Catalog connection this gateway pipeline uses to communicate with the source. """ + connection_name: NotRequired[pulumi.Input[str]] gateway_storage_catalog: NotRequired[pulumi.Input[str]] """ Required, Immutable. The name of the catalog for the gateway pipeline's storage location. @@ -27863,6 +27866,7 @@ class PipelineGatewayDefinitionArgsDict(TypedDict): class PipelineGatewayDefinitionArgs: def __init__(__self__, *, connection_id: Optional[pulumi.Input[str]] = None, + connection_name: Optional[pulumi.Input[str]] = None, gateway_storage_catalog: Optional[pulumi.Input[str]] = None, gateway_storage_name: Optional[pulumi.Input[str]] = None, gateway_storage_schema: Optional[pulumi.Input[str]] = None): @@ -27874,6 +27878,8 @@ def __init__(__self__, *, """ if connection_id is not None: pulumi.set(__self__, "connection_id", connection_id) + if connection_name is not None: + pulumi.set(__self__, "connection_name", connection_name) if gateway_storage_catalog is not None: pulumi.set(__self__, "gateway_storage_catalog", gateway_storage_catalog) if gateway_storage_name is not None: @@ -27893,6 +27899,15 @@ def connection_id(self) -> Optional[pulumi.Input[str]]: def connection_id(self, value: Optional[pulumi.Input[str]]): pulumi.set(self, "connection_id", value) + @property + @pulumi.getter(name="connectionName") + def connection_name(self) -> Optional[pulumi.Input[str]]: + return pulumi.get(self, "connection_name") + + @connection_name.setter + def connection_name(self, value: Optional[pulumi.Input[str]]): + pulumi.set(self, "connection_name", value) + @property @pulumi.getter(name="gatewayStorageCatalog") def gateway_storage_catalog(self) -> Optional[pulumi.Input[str]]: @@ -28835,6 +28850,54 @@ def email_recipients(self, value: Optional[pulumi.Input[Sequence[pulumi.Input[st pulumi.set(self, "email_recipients", value) +if not MYPY: + class PipelineRestartWindowArgsDict(TypedDict): + start_hour: pulumi.Input[int] + days_of_week: NotRequired[pulumi.Input[str]] + time_zone_id: NotRequired[pulumi.Input[str]] +elif False: + PipelineRestartWindowArgsDict: TypeAlias = Mapping[str, Any] + +@pulumi.input_type +class PipelineRestartWindowArgs: + def __init__(__self__, *, + start_hour: pulumi.Input[int], + days_of_week: Optional[pulumi.Input[str]] = None, + time_zone_id: Optional[pulumi.Input[str]] = None): + pulumi.set(__self__, "start_hour", start_hour) + if days_of_week is not None: + pulumi.set(__self__, "days_of_week", days_of_week) + if time_zone_id is not None: + pulumi.set(__self__, "time_zone_id", time_zone_id) + + @property + @pulumi.getter(name="startHour") + def start_hour(self) -> pulumi.Input[int]: + return pulumi.get(self, "start_hour") + + @start_hour.setter + def start_hour(self, value: pulumi.Input[int]): + pulumi.set(self, "start_hour", value) + + @property + @pulumi.getter(name="daysOfWeek") + def days_of_week(self) -> Optional[pulumi.Input[str]]: + return pulumi.get(self, "days_of_week") + + @days_of_week.setter + def days_of_week(self, value: Optional[pulumi.Input[str]]): + pulumi.set(self, "days_of_week", value) + + @property + @pulumi.getter(name="timeZoneId") + def time_zone_id(self) -> Optional[pulumi.Input[str]]: + return pulumi.get(self, "time_zone_id") + + @time_zone_id.setter + def time_zone_id(self, value: Optional[pulumi.Input[str]]): + pulumi.set(self, "time_zone_id", value) + + if not MYPY: class PipelineTriggerArgsDict(TypedDict): cron: NotRequired[pulumi.Input['PipelineTriggerCronArgsDict']] @@ -54592,6 +54655,7 @@ class GetStorageCredentialStorageCredentialInfoArgsDict(TypedDict): """ credential details for GCP: """ + full_name: NotRequired[str] id: NotRequired[str] """ Unique ID of storage credential. @@ -54636,6 +54700,7 @@ def __init__(__self__, *, created_at: Optional[int] = None, created_by: Optional[str] = None, databricks_gcp_service_account: Optional['GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccountArgs'] = None, + full_name: Optional[str] = None, id: Optional[str] = None, isolation_mode: Optional[str] = None, metastore_id: Optional[str] = None, @@ -54676,6 +54741,8 @@ def __init__(__self__, *, pulumi.set(__self__, "created_by", created_by) if databricks_gcp_service_account is not None: pulumi.set(__self__, "databricks_gcp_service_account", databricks_gcp_service_account) + if full_name is not None: + pulumi.set(__self__, "full_name", full_name) if id is not None: pulumi.set(__self__, "id", id) if isolation_mode is not None: @@ -54785,6 +54852,15 @@ def databricks_gcp_service_account(self) -> Optional['GetStorageCredentialStorag def databricks_gcp_service_account(self, value: Optional['GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccountArgs']): pulumi.set(self, "databricks_gcp_service_account", value) + @property + @pulumi.getter(name="fullName") + def full_name(self) -> Optional[str]: + return pulumi.get(self, "full_name") + + @full_name.setter + def full_name(self, value: Optional[str]): + pulumi.set(self, "full_name", value) + @property @pulumi.getter def id(self) -> Optional[str]: diff --git a/sdk/python/pulumi_databricks/outputs.py b/sdk/python/pulumi_databricks/outputs.py index 573cf131..02be5a87 100644 --- a/sdk/python/pulumi_databricks/outputs.py +++ b/sdk/python/pulumi_databricks/outputs.py @@ -419,6 +419,7 @@ 'PipelineLibraryMaven', 'PipelineLibraryNotebook', 'PipelineNotification', + 'PipelineRestartWindow', 'PipelineTrigger', 'PipelineTriggerCron', 'PipelineTriggerManual', @@ -21370,6 +21371,8 @@ def __key_warning(key: str): suggest = None if key == "connectionId": suggest = "connection_id" + elif key == "connectionName": + suggest = "connection_name" elif key == "gatewayStorageCatalog": suggest = "gateway_storage_catalog" elif key == "gatewayStorageName": @@ -21390,6 +21393,7 @@ def get(self, key: str, default = None) -> Any: def __init__(__self__, *, connection_id: Optional[str] = None, + connection_name: Optional[str] = None, gateway_storage_catalog: Optional[str] = None, gateway_storage_name: Optional[str] = None, gateway_storage_schema: Optional[str] = None): @@ -21401,6 +21405,8 @@ def __init__(__self__, *, """ if connection_id is not None: pulumi.set(__self__, "connection_id", connection_id) + if connection_name is not None: + pulumi.set(__self__, "connection_name", connection_name) if gateway_storage_catalog is not None: pulumi.set(__self__, "gateway_storage_catalog", gateway_storage_catalog) if gateway_storage_name is not None: @@ -21416,6 +21422,11 @@ def connection_id(self) -> Optional[str]: """ return pulumi.get(self, "connection_id") + @property + @pulumi.getter(name="connectionName") + def connection_name(self) -> Optional[str]: + return pulumi.get(self, "connection_name") + @property @pulumi.getter(name="gatewayStorageCatalog") def gateway_storage_catalog(self) -> Optional[str]: @@ -22208,6 +22219,55 @@ def email_recipients(self) -> Optional[Sequence[str]]: return pulumi.get(self, "email_recipients") +@pulumi.output_type +class PipelineRestartWindow(dict): + @staticmethod + def __key_warning(key: str): + suggest = None + if key == "startHour": + suggest = "start_hour" + elif key == "daysOfWeek": + suggest = "days_of_week" + elif key == "timeZoneId": + suggest = "time_zone_id" + + if suggest: + pulumi.log.warn(f"Key '{key}' not found in PipelineRestartWindow. Access the value via the '{suggest}' property getter instead.") + + def __getitem__(self, key: str) -> Any: + PipelineRestartWindow.__key_warning(key) + return super().__getitem__(key) + + def get(self, key: str, default = None) -> Any: + PipelineRestartWindow.__key_warning(key) + return super().get(key, default) + + def __init__(__self__, *, + start_hour: int, + days_of_week: Optional[str] = None, + time_zone_id: Optional[str] = None): + pulumi.set(__self__, "start_hour", start_hour) + if days_of_week is not None: + pulumi.set(__self__, "days_of_week", days_of_week) + if time_zone_id is not None: + pulumi.set(__self__, "time_zone_id", time_zone_id) + + @property + @pulumi.getter(name="startHour") + def start_hour(self) -> int: + return pulumi.get(self, "start_hour") + + @property + @pulumi.getter(name="daysOfWeek") + def days_of_week(self) -> Optional[str]: + return pulumi.get(self, "days_of_week") + + @property + @pulumi.getter(name="timeZoneId") + def time_zone_id(self) -> Optional[str]: + return pulumi.get(self, "time_zone_id") + + @pulumi.output_type class PipelineTrigger(dict): def __init__(__self__, *, @@ -38396,6 +38456,7 @@ def __init__(__self__, *, created_at: Optional[int] = None, created_by: Optional[str] = None, databricks_gcp_service_account: Optional['outputs.GetStorageCredentialStorageCredentialInfoDatabricksGcpServiceAccountResult'] = None, + full_name: Optional[str] = None, id: Optional[str] = None, isolation_mode: Optional[str] = None, metastore_id: Optional[str] = None, @@ -38436,6 +38497,8 @@ def __init__(__self__, *, pulumi.set(__self__, "created_by", created_by) if databricks_gcp_service_account is not None: pulumi.set(__self__, "databricks_gcp_service_account", databricks_gcp_service_account) + if full_name is not None: + pulumi.set(__self__, "full_name", full_name) if id is not None: pulumi.set(__self__, "id", id) if isolation_mode is not None: @@ -38513,6 +38576,11 @@ def databricks_gcp_service_account(self) -> Optional['outputs.GetStorageCredenti """ return pulumi.get(self, "databricks_gcp_service_account") + @property + @pulumi.getter(name="fullName") + def full_name(self) -> Optional[str]: + return pulumi.get(self, "full_name") + @property @pulumi.getter def id(self) -> Optional[str]: diff --git a/sdk/python/pulumi_databricks/pipeline.py b/sdk/python/pulumi_databricks/pipeline.py index 1ebe05fb..c2a58d02 100644 --- a/sdk/python/pulumi_databricks/pipeline.py +++ b/sdk/python/pulumi_databricks/pipeline.py @@ -45,6 +45,7 @@ def __init__(__self__, *, name: Optional[pulumi.Input[str]] = None, notifications: Optional[pulumi.Input[Sequence[pulumi.Input['PipelineNotificationArgs']]]] = None, photon: Optional[pulumi.Input[bool]] = None, + restart_window: Optional[pulumi.Input['PipelineRestartWindowArgs']] = None, run_as_user_name: Optional[pulumi.Input[str]] = None, schema: Optional[pulumi.Input[str]] = None, serverless: Optional[pulumi.Input[bool]] = None, @@ -124,6 +125,8 @@ def __init__(__self__, *, pulumi.set(__self__, "notifications", notifications) if photon is not None: pulumi.set(__self__, "photon", photon) + if restart_window is not None: + pulumi.set(__self__, "restart_window", restart_window) if run_as_user_name is not None: pulumi.set(__self__, "run_as_user_name", run_as_user_name) if schema is not None: @@ -402,6 +405,15 @@ def photon(self) -> Optional[pulumi.Input[bool]]: def photon(self, value: Optional[pulumi.Input[bool]]): pulumi.set(self, "photon", value) + @property + @pulumi.getter(name="restartWindow") + def restart_window(self) -> Optional[pulumi.Input['PipelineRestartWindowArgs']]: + return pulumi.get(self, "restart_window") + + @restart_window.setter + def restart_window(self, value: Optional[pulumi.Input['PipelineRestartWindowArgs']]): + pulumi.set(self, "restart_window", value) + @property @pulumi.getter(name="runAsUserName") def run_as_user_name(self) -> Optional[pulumi.Input[str]]: @@ -517,6 +529,7 @@ def __init__(__self__, *, name: Optional[pulumi.Input[str]] = None, notifications: Optional[pulumi.Input[Sequence[pulumi.Input['PipelineNotificationArgs']]]] = None, photon: Optional[pulumi.Input[bool]] = None, + restart_window: Optional[pulumi.Input['PipelineRestartWindowArgs']] = None, run_as_user_name: Optional[pulumi.Input[str]] = None, schema: Optional[pulumi.Input[str]] = None, serverless: Optional[pulumi.Input[bool]] = None, @@ -596,6 +609,8 @@ def __init__(__self__, *, pulumi.set(__self__, "notifications", notifications) if photon is not None: pulumi.set(__self__, "photon", photon) + if restart_window is not None: + pulumi.set(__self__, "restart_window", restart_window) if run_as_user_name is not None: pulumi.set(__self__, "run_as_user_name", run_as_user_name) if schema is not None: @@ -874,6 +889,15 @@ def photon(self) -> Optional[pulumi.Input[bool]]: def photon(self, value: Optional[pulumi.Input[bool]]): pulumi.set(self, "photon", value) + @property + @pulumi.getter(name="restartWindow") + def restart_window(self) -> Optional[pulumi.Input['PipelineRestartWindowArgs']]: + return pulumi.get(self, "restart_window") + + @restart_window.setter + def restart_window(self, value: Optional[pulumi.Input['PipelineRestartWindowArgs']]): + pulumi.set(self, "restart_window", value) + @property @pulumi.getter(name="runAsUserName") def run_as_user_name(self) -> Optional[pulumi.Input[str]]: @@ -991,6 +1015,7 @@ def __init__(__self__, name: Optional[pulumi.Input[str]] = None, notifications: Optional[pulumi.Input[Sequence[pulumi.Input[Union['PipelineNotificationArgs', 'PipelineNotificationArgsDict']]]]] = None, photon: Optional[pulumi.Input[bool]] = None, + restart_window: Optional[pulumi.Input[Union['PipelineRestartWindowArgs', 'PipelineRestartWindowArgsDict']]] = None, run_as_user_name: Optional[pulumi.Input[str]] = None, schema: Optional[pulumi.Input[str]] = None, serverless: Optional[pulumi.Input[bool]] = None, @@ -1230,6 +1255,7 @@ def _internal_init(__self__, name: Optional[pulumi.Input[str]] = None, notifications: Optional[pulumi.Input[Sequence[pulumi.Input[Union['PipelineNotificationArgs', 'PipelineNotificationArgsDict']]]]] = None, photon: Optional[pulumi.Input[bool]] = None, + restart_window: Optional[pulumi.Input[Union['PipelineRestartWindowArgs', 'PipelineRestartWindowArgsDict']]] = None, run_as_user_name: Optional[pulumi.Input[str]] = None, schema: Optional[pulumi.Input[str]] = None, serverless: Optional[pulumi.Input[bool]] = None, @@ -1271,6 +1297,7 @@ def _internal_init(__self__, __props__.__dict__["name"] = name __props__.__dict__["notifications"] = notifications __props__.__dict__["photon"] = photon + __props__.__dict__["restart_window"] = restart_window __props__.__dict__["run_as_user_name"] = run_as_user_name __props__.__dict__["schema"] = schema __props__.__dict__["serverless"] = serverless @@ -1313,6 +1340,7 @@ def get(resource_name: str, name: Optional[pulumi.Input[str]] = None, notifications: Optional[pulumi.Input[Sequence[pulumi.Input[Union['PipelineNotificationArgs', 'PipelineNotificationArgsDict']]]]] = None, photon: Optional[pulumi.Input[bool]] = None, + restart_window: Optional[pulumi.Input[Union['PipelineRestartWindowArgs', 'PipelineRestartWindowArgsDict']]] = None, run_as_user_name: Optional[pulumi.Input[str]] = None, schema: Optional[pulumi.Input[str]] = None, serverless: Optional[pulumi.Input[bool]] = None, @@ -1377,6 +1405,7 @@ def get(resource_name: str, __props__.__dict__["name"] = name __props__.__dict__["notifications"] = notifications __props__.__dict__["photon"] = photon + __props__.__dict__["restart_window"] = restart_window __props__.__dict__["run_as_user_name"] = run_as_user_name __props__.__dict__["schema"] = schema __props__.__dict__["serverless"] = serverless @@ -1552,6 +1581,11 @@ def photon(self) -> pulumi.Output[Optional[bool]]: """ return pulumi.get(self, "photon") + @property + @pulumi.getter(name="restartWindow") + def restart_window(self) -> pulumi.Output[Optional['outputs.PipelineRestartWindow']]: + return pulumi.get(self, "restart_window") + @property @pulumi.getter(name="runAsUserName") def run_as_user_name(self) -> pulumi.Output[str]: