From 0cbbb8f18ceb5502519c8858ff8c2d141fc692a4 Mon Sep 17 00:00:00 2001 From: Azure SDK for Python bot Date: Thu, 29 Aug 2019 20:31:53 -0700 Subject: [PATCH] Generated from 5e1bb35d5c3314d8f4fead76c3d69a2522be026b (#5651) Update review comments --- .../datafactory/mgmt/datafactory/models.go | 3 + .../datafactory/mgmt/datafactory/models.go | 3 + .../mgmt/2018-06-01/datafactory/models.go | 290 +++++++++++++++++- 3 files changed, 288 insertions(+), 8 deletions(-) diff --git a/profiles/latest/datafactory/mgmt/datafactory/models.go b/profiles/latest/datafactory/mgmt/datafactory/models.go index 6a2a948586a1..9890eca03d73 100644 --- a/profiles/latest/datafactory/mgmt/datafactory/models.go +++ b/profiles/latest/datafactory/mgmt/datafactory/models.go @@ -1084,6 +1084,7 @@ type TypeBasicTrigger = original.TypeBasicTrigger const ( TypeBlobEventsTrigger TypeBasicTrigger = original.TypeBlobEventsTrigger TypeBlobTrigger TypeBasicTrigger = original.TypeBlobTrigger + TypeChainingTrigger TypeBasicTrigger = original.TypeChainingTrigger TypeMultiplePipelineTrigger TypeBasicTrigger = original.TypeMultiplePipelineTrigger TypeRerunTumblingWindowTrigger TypeBasicTrigger = original.TypeRerunTumblingWindowTrigger TypeScheduleTrigger TypeBasicTrigger = original.TypeScheduleTrigger @@ -1277,6 +1278,8 @@ type CassandraLinkedServiceTypeProperties = original.CassandraLinkedServiceTypeP type CassandraSource = original.CassandraSource type CassandraTableDataset = original.CassandraTableDataset type CassandraTableDatasetTypeProperties = original.CassandraTableDatasetTypeProperties +type ChainingTrigger = original.ChainingTrigger +type ChainingTriggerTypeProperties = original.ChainingTriggerTypeProperties type CloudError = original.CloudError type CloudErrorBody = original.CloudErrorBody type CommonDataServiceForAppsEntityDataset = original.CommonDataServiceForAppsEntityDataset diff --git a/profiles/preview/datafactory/mgmt/datafactory/models.go b/profiles/preview/datafactory/mgmt/datafactory/models.go index 5b7373730a53..3962028caf09 100644 --- a/profiles/preview/datafactory/mgmt/datafactory/models.go +++ b/profiles/preview/datafactory/mgmt/datafactory/models.go @@ -1084,6 +1084,7 @@ type TypeBasicTrigger = original.TypeBasicTrigger const ( TypeBlobEventsTrigger TypeBasicTrigger = original.TypeBlobEventsTrigger TypeBlobTrigger TypeBasicTrigger = original.TypeBlobTrigger + TypeChainingTrigger TypeBasicTrigger = original.TypeChainingTrigger TypeMultiplePipelineTrigger TypeBasicTrigger = original.TypeMultiplePipelineTrigger TypeRerunTumblingWindowTrigger TypeBasicTrigger = original.TypeRerunTumblingWindowTrigger TypeScheduleTrigger TypeBasicTrigger = original.TypeScheduleTrigger @@ -1277,6 +1278,8 @@ type CassandraLinkedServiceTypeProperties = original.CassandraLinkedServiceTypeP type CassandraSource = original.CassandraSource type CassandraTableDataset = original.CassandraTableDataset type CassandraTableDatasetTypeProperties = original.CassandraTableDatasetTypeProperties +type ChainingTrigger = original.ChainingTrigger +type ChainingTriggerTypeProperties = original.ChainingTriggerTypeProperties type CloudError = original.CloudError type CloudErrorBody = original.CloudErrorBody type CommonDataServiceForAppsEntityDataset = original.CommonDataServiceForAppsEntityDataset diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/models.go b/services/datafactory/mgmt/2018-06-01/datafactory/models.go index dd3c922d71a8..d2646b9b0280 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/models.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/models.go @@ -2229,6 +2229,8 @@ const ( TypeBlobEventsTrigger TypeBasicTrigger = "BlobEventsTrigger" // TypeBlobTrigger ... TypeBlobTrigger TypeBasicTrigger = "BlobTrigger" + // TypeChainingTrigger ... + TypeChainingTrigger TypeBasicTrigger = "ChainingTrigger" // TypeMultiplePipelineTrigger ... TypeMultiplePipelineTrigger TypeBasicTrigger = "MultiplePipelineTrigger" // TypeRerunTumblingWindowTrigger ... @@ -2243,7 +2245,7 @@ const ( // PossibleTypeBasicTriggerValues returns an array of possible values for the TypeBasicTrigger const type. func PossibleTypeBasicTriggerValues() []TypeBasicTrigger { - return []TypeBasicTrigger{TypeBlobEventsTrigger, TypeBlobTrigger, TypeMultiplePipelineTrigger, TypeRerunTumblingWindowTrigger, TypeScheduleTrigger, TypeTrigger, TypeTumblingWindowTrigger} + return []TypeBasicTrigger{TypeBlobEventsTrigger, TypeBlobTrigger, TypeChainingTrigger, TypeMultiplePipelineTrigger, TypeRerunTumblingWindowTrigger, TypeScheduleTrigger, TypeTrigger, TypeTumblingWindowTrigger} } // VariableType enumerates the values for variable type. @@ -42084,7 +42086,7 @@ type BlobEventsTrigger struct { RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Annotations - List of tags that can be used for describing the trigger. Annotations *[]interface{} `json:"annotations,omitempty"` - // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' + // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeChainingTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` } @@ -42118,6 +42120,11 @@ func (bet BlobEventsTrigger) AsRerunTumblingWindowTrigger() (*RerunTumblingWindo return nil, false } +// AsChainingTrigger is the BasicTrigger implementation for BlobEventsTrigger. +func (bet BlobEventsTrigger) AsChainingTrigger() (*ChainingTrigger, bool) { + return nil, false +} + // AsTumblingWindowTrigger is the BasicTrigger implementation for BlobEventsTrigger. func (bet BlobEventsTrigger) AsTumblingWindowTrigger() (*TumblingWindowTrigger, bool) { return nil, false @@ -43189,7 +43196,7 @@ type BlobTrigger struct { RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Annotations - List of tags that can be used for describing the trigger. Annotations *[]interface{} `json:"annotations,omitempty"` - // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' + // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeChainingTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` } @@ -43223,6 +43230,11 @@ func (bt BlobTrigger) AsRerunTumblingWindowTrigger() (*RerunTumblingWindowTrigge return nil, false } +// AsChainingTrigger is the BasicTrigger implementation for BlobTrigger. +func (bt BlobTrigger) AsChainingTrigger() (*ChainingTrigger, bool) { + return nil, false +} + // AsTumblingWindowTrigger is the BasicTrigger implementation for BlobTrigger. func (bt BlobTrigger) AsTumblingWindowTrigger() (*TumblingWindowTrigger, bool) { return nil, false @@ -45199,6 +45211,191 @@ type CassandraTableDatasetTypeProperties struct { Keyspace interface{} `json:"keyspace,omitempty"` } +// ChainingTrigger trigger that allows the referenced pipeline to depend on other pipeline runs based on +// runDimension Name/Value pairs. Upstream pipelines should declare the same runDimension Name and their +// runs should have the values for those runDimensions. The referenced pipeline run would be triggered if +// the values for the runDimension match for all upstream pipeline runs. +type ChainingTrigger struct { + // Pipeline - Pipeline for which runs are created when all upstream pipelines complete successfully. + Pipeline *TriggerPipelineReference `json:"pipeline,omitempty"` + // ChainingTriggerTypeProperties - Chaining Trigger properties. + *ChainingTriggerTypeProperties `json:"typeProperties,omitempty"` + // AdditionalProperties - Unmatched properties from the message are deserialized this collection + AdditionalProperties map[string]interface{} `json:""` + // Description - Trigger description. + Description *string `json:"description,omitempty"` + // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'TriggerRuntimeStateStarted', 'TriggerRuntimeStateStopped', 'TriggerRuntimeStateDisabled' + RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` + // Annotations - List of tags that can be used for describing the trigger. + Annotations *[]interface{} `json:"annotations,omitempty"` + // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeChainingTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' + Type TypeBasicTrigger `json:"type,omitempty"` +} + +// MarshalJSON is the custom marshaler for ChainingTrigger. +func (ct ChainingTrigger) MarshalJSON() ([]byte, error) { + ct.Type = TypeChainingTrigger + objectMap := make(map[string]interface{}) + if ct.Pipeline != nil { + objectMap["pipeline"] = ct.Pipeline + } + if ct.ChainingTriggerTypeProperties != nil { + objectMap["typeProperties"] = ct.ChainingTriggerTypeProperties + } + if ct.Description != nil { + objectMap["description"] = ct.Description + } + if ct.Annotations != nil { + objectMap["annotations"] = ct.Annotations + } + if ct.Type != "" { + objectMap["type"] = ct.Type + } + for k, v := range ct.AdditionalProperties { + objectMap[k] = v + } + return json.Marshal(objectMap) +} + +// AsRerunTumblingWindowTrigger is the BasicTrigger implementation for ChainingTrigger. +func (ct ChainingTrigger) AsRerunTumblingWindowTrigger() (*RerunTumblingWindowTrigger, bool) { + return nil, false +} + +// AsChainingTrigger is the BasicTrigger implementation for ChainingTrigger. +func (ct ChainingTrigger) AsChainingTrigger() (*ChainingTrigger, bool) { + return &ct, true +} + +// AsTumblingWindowTrigger is the BasicTrigger implementation for ChainingTrigger. +func (ct ChainingTrigger) AsTumblingWindowTrigger() (*TumblingWindowTrigger, bool) { + return nil, false +} + +// AsBlobEventsTrigger is the BasicTrigger implementation for ChainingTrigger. +func (ct ChainingTrigger) AsBlobEventsTrigger() (*BlobEventsTrigger, bool) { + return nil, false +} + +// AsBlobTrigger is the BasicTrigger implementation for ChainingTrigger. +func (ct ChainingTrigger) AsBlobTrigger() (*BlobTrigger, bool) { + return nil, false +} + +// AsScheduleTrigger is the BasicTrigger implementation for ChainingTrigger. +func (ct ChainingTrigger) AsScheduleTrigger() (*ScheduleTrigger, bool) { + return nil, false +} + +// AsMultiplePipelineTrigger is the BasicTrigger implementation for ChainingTrigger. +func (ct ChainingTrigger) AsMultiplePipelineTrigger() (*MultiplePipelineTrigger, bool) { + return nil, false +} + +// AsBasicMultiplePipelineTrigger is the BasicTrigger implementation for ChainingTrigger. +func (ct ChainingTrigger) AsBasicMultiplePipelineTrigger() (BasicMultiplePipelineTrigger, bool) { + return nil, false +} + +// AsTrigger is the BasicTrigger implementation for ChainingTrigger. +func (ct ChainingTrigger) AsTrigger() (*Trigger, bool) { + return nil, false +} + +// AsBasicTrigger is the BasicTrigger implementation for ChainingTrigger. +func (ct ChainingTrigger) AsBasicTrigger() (BasicTrigger, bool) { + return &ct, true +} + +// UnmarshalJSON is the custom unmarshaler for ChainingTrigger struct. +func (ct *ChainingTrigger) UnmarshalJSON(body []byte) error { + var m map[string]*json.RawMessage + err := json.Unmarshal(body, &m) + if err != nil { + return err + } + for k, v := range m { + switch k { + case "pipeline": + if v != nil { + var pipeline TriggerPipelineReference + err = json.Unmarshal(*v, &pipeline) + if err != nil { + return err + } + ct.Pipeline = &pipeline + } + case "typeProperties": + if v != nil { + var chainingTriggerTypeProperties ChainingTriggerTypeProperties + err = json.Unmarshal(*v, &chainingTriggerTypeProperties) + if err != nil { + return err + } + ct.ChainingTriggerTypeProperties = &chainingTriggerTypeProperties + } + default: + if v != nil { + var additionalProperties interface{} + err = json.Unmarshal(*v, &additionalProperties) + if err != nil { + return err + } + if ct.AdditionalProperties == nil { + ct.AdditionalProperties = make(map[string]interface{}) + } + ct.AdditionalProperties[k] = additionalProperties + } + case "description": + if v != nil { + var description string + err = json.Unmarshal(*v, &description) + if err != nil { + return err + } + ct.Description = &description + } + case "runtimeState": + if v != nil { + var runtimeState TriggerRuntimeState + err = json.Unmarshal(*v, &runtimeState) + if err != nil { + return err + } + ct.RuntimeState = runtimeState + } + case "annotations": + if v != nil { + var annotations []interface{} + err = json.Unmarshal(*v, &annotations) + if err != nil { + return err + } + ct.Annotations = &annotations + } + case "type": + if v != nil { + var typeVar TypeBasicTrigger + err = json.Unmarshal(*v, &typeVar) + if err != nil { + return err + } + ct.Type = typeVar + } + } + } + + return nil +} + +// ChainingTriggerTypeProperties chaining Trigger properties. +type ChainingTriggerTypeProperties struct { + // DependsOn - Upstream Pipelines. + DependsOn *[]PipelineReference `json:"dependsOn,omitempty"` + // RunDimension - Run Dimension property that needs to be emitted by upstream pipelines. + RunDimension *string `json:"runDimension,omitempty"` +} + // CloudError the object that defines the structure of an Azure Data Factory error response. type CloudError struct { // CloudErrorBody - Error data @@ -124457,7 +124654,7 @@ type MultiplePipelineTrigger struct { RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Annotations - List of tags that can be used for describing the trigger. Annotations *[]interface{} `json:"annotations,omitempty"` - // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' + // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeChainingTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` } @@ -124533,6 +124730,11 @@ func (mpt MultiplePipelineTrigger) AsRerunTumblingWindowTrigger() (*RerunTumblin return nil, false } +// AsChainingTrigger is the BasicTrigger implementation for MultiplePipelineTrigger. +func (mpt MultiplePipelineTrigger) AsChainingTrigger() (*ChainingTrigger, bool) { + return nil, false +} + // AsTumblingWindowTrigger is the BasicTrigger implementation for MultiplePipelineTrigger. func (mpt MultiplePipelineTrigger) AsTumblingWindowTrigger() (*TumblingWindowTrigger, bool) { return nil, false @@ -143865,6 +144067,8 @@ type Pipeline struct { Concurrency *int32 `json:"concurrency,omitempty"` // Annotations - List of tags that can be used for describing the Pipeline. Annotations *[]interface{} `json:"annotations,omitempty"` + // RunDimensions - Dimensions emitted by Pipeline. + RunDimensions map[string]interface{} `json:"runDimensions"` // Folder - The folder that this Pipeline is in. If not specified, Pipeline will appear at the root level. Folder *PipelineFolder `json:"folder,omitempty"` } @@ -143890,6 +144094,9 @@ func (p Pipeline) MarshalJSON() ([]byte, error) { if p.Annotations != nil { objectMap["annotations"] = p.Annotations } + if p.RunDimensions != nil { + objectMap["runDimensions"] = p.RunDimensions + } if p.Folder != nil { objectMap["folder"] = p.Folder } @@ -143958,6 +144165,15 @@ func (p *Pipeline) UnmarshalJSON(body []byte) error { } p.Annotations = &annotations } + case "runDimensions": + if v != nil { + var runDimensions map[string]interface{} + err = json.Unmarshal(*v, &runDimensions) + if err != nil { + return err + } + p.RunDimensions = runDimensions + } case "folder": if v != nil { var folder PipelineFolder @@ -144252,6 +144468,8 @@ type PipelineRun struct { PipelineName *string `json:"pipelineName,omitempty"` // Parameters - READ-ONLY; The full or partial list of parameter name, value pair used in the pipeline run. Parameters map[string]*string `json:"parameters"` + // RunDimensions - READ-ONLY; Run dimensions emitted by Pipeline run. + RunDimensions map[string]*string `json:"runDimensions"` // InvokedBy - READ-ONLY; Entity that started the pipeline run. InvokedBy *PipelineRunInvokedBy `json:"invokedBy,omitempty"` // LastUpdated - READ-ONLY; The last updated timestamp for the pipeline run event in ISO8601 format. @@ -144343,6 +144561,15 @@ func (pr *PipelineRun) UnmarshalJSON(body []byte) error { } pr.Parameters = parameters } + case "runDimensions": + if v != nil { + var runDimensions map[string]*string + err = json.Unmarshal(*v, &runDimensions) + if err != nil { + return err + } + pr.RunDimensions = runDimensions + } case "invokedBy": if v != nil { var invokedBy PipelineRunInvokedBy @@ -151750,7 +151977,7 @@ type RerunTumblingWindowTrigger struct { RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Annotations - List of tags that can be used for describing the trigger. Annotations *[]interface{} `json:"annotations,omitempty"` - // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' + // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeChainingTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` } @@ -151781,6 +152008,11 @@ func (rtwt RerunTumblingWindowTrigger) AsRerunTumblingWindowTrigger() (*RerunTum return &rtwt, true } +// AsChainingTrigger is the BasicTrigger implementation for RerunTumblingWindowTrigger. +func (rtwt RerunTumblingWindowTrigger) AsChainingTrigger() (*ChainingTrigger, bool) { + return nil, false +} + // AsTumblingWindowTrigger is the BasicTrigger implementation for RerunTumblingWindowTrigger. func (rtwt RerunTumblingWindowTrigger) AsTumblingWindowTrigger() (*TumblingWindowTrigger, bool) { return nil, false @@ -173444,7 +173676,7 @@ type ScheduleTrigger struct { RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Annotations - List of tags that can be used for describing the trigger. Annotations *[]interface{} `json:"annotations,omitempty"` - // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' + // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeChainingTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` } @@ -173478,6 +173710,11 @@ func (st ScheduleTrigger) AsRerunTumblingWindowTrigger() (*RerunTumblingWindowTr return nil, false } +// AsChainingTrigger is the BasicTrigger implementation for ScheduleTrigger. +func (st ScheduleTrigger) AsChainingTrigger() (*ChainingTrigger, bool) { + return nil, false +} + // AsTumblingWindowTrigger is the BasicTrigger implementation for ScheduleTrigger. func (st ScheduleTrigger) AsTumblingWindowTrigger() (*TumblingWindowTrigger, bool) { return nil, false @@ -193446,6 +193683,7 @@ func (tf *TextFormat) UnmarshalJSON(body []byte) error { // BasicTrigger azure data factory nested object which contains information about creating pipeline run type BasicTrigger interface { AsRerunTumblingWindowTrigger() (*RerunTumblingWindowTrigger, bool) + AsChainingTrigger() (*ChainingTrigger, bool) AsTumblingWindowTrigger() (*TumblingWindowTrigger, bool) AsBlobEventsTrigger() (*BlobEventsTrigger, bool) AsBlobTrigger() (*BlobTrigger, bool) @@ -193465,7 +193703,7 @@ type Trigger struct { RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Annotations - List of tags that can be used for describing the trigger. Annotations *[]interface{} `json:"annotations,omitempty"` - // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' + // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeChainingTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` } @@ -193481,6 +193719,10 @@ func unmarshalBasicTrigger(body []byte) (BasicTrigger, error) { var rtwt RerunTumblingWindowTrigger err := json.Unmarshal(body, &rtwt) return rtwt, err + case string(TypeChainingTrigger): + var ct ChainingTrigger + err := json.Unmarshal(body, &ct) + return ct, err case string(TypeTumblingWindowTrigger): var twt TumblingWindowTrigger err := json.Unmarshal(body, &twt) @@ -193550,6 +193792,11 @@ func (t Trigger) AsRerunTumblingWindowTrigger() (*RerunTumblingWindowTrigger, bo return nil, false } +// AsChainingTrigger is the BasicTrigger implementation for Trigger. +func (t Trigger) AsChainingTrigger() (*ChainingTrigger, bool) { + return nil, false +} + // AsTumblingWindowTrigger is the BasicTrigger implementation for Trigger. func (t Trigger) AsTumblingWindowTrigger() (*TumblingWindowTrigger, bool) { return nil, false @@ -194015,6 +194262,10 @@ type TriggerRun struct { Properties map[string]*string `json:"properties"` // TriggeredPipelines - READ-ONLY; List of pipeline name and run Id triggered by the trigger run. TriggeredPipelines map[string]*string `json:"triggeredPipelines"` + // RunDimension - READ-ONLY; Run dimension for which trigger was fired. + RunDimension map[string]*string `json:"runDimension"` + // DependencyStatus - READ-ONLY; Status of the upstream pipelines. + DependencyStatus map[string]interface{} `json:"dependencyStatus"` } // MarshalJSON is the custom marshaler for TriggerRun. @@ -194119,6 +194370,24 @@ func (tr *TriggerRun) UnmarshalJSON(body []byte) error { } tr.TriggeredPipelines = triggeredPipelines } + case "runDimension": + if v != nil { + var runDimension map[string]*string + err = json.Unmarshal(*v, &runDimension) + if err != nil { + return err + } + tr.RunDimension = runDimension + } + case "dependencyStatus": + if v != nil { + var dependencyStatus map[string]interface{} + err = json.Unmarshal(*v, &dependencyStatus) + if err != nil { + return err + } + tr.DependencyStatus = dependencyStatus + } } } @@ -194261,7 +194530,7 @@ type TumblingWindowTrigger struct { RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Annotations - List of tags that can be used for describing the trigger. Annotations *[]interface{} `json:"annotations,omitempty"` - // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' + // Type - Possible values include: 'TypeTrigger', 'TypeRerunTumblingWindowTrigger', 'TypeChainingTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` } @@ -194295,6 +194564,11 @@ func (twt TumblingWindowTrigger) AsRerunTumblingWindowTrigger() (*RerunTumblingW return nil, false } +// AsChainingTrigger is the BasicTrigger implementation for TumblingWindowTrigger. +func (twt TumblingWindowTrigger) AsChainingTrigger() (*ChainingTrigger, bool) { + return nil, false +} + // AsTumblingWindowTrigger is the BasicTrigger implementation for TumblingWindowTrigger. func (twt TumblingWindowTrigger) AsTumblingWindowTrigger() (*TumblingWindowTrigger, bool) { return &twt, true