File tree Expand file tree Collapse file tree 4 files changed +9
-10
lines changed
testrunner/runners/system
test/packages/parallel/gcp
data_stream/compute/_dev/test/system Expand file tree Collapse file tree 4 files changed +9
-10
lines changed Original file line number Diff line number Diff line change @@ -189,6 +189,7 @@ type PackageDataStream struct {
189189 Enabled bool `json:"enabled"`
190190 OutputID string `json:"output_id"`
191191 Inputs []Input `json:"inputs"`
192+ Vars Vars `json:"vars,omitempty"`
192193 Package struct {
193194 Name string `json:"name"`
194195 Title string `json:"title"`
Original file line number Diff line number Diff line change @@ -582,16 +582,14 @@ func createIntegrationPackageDatastream(
582582 streams [0 ].Vars = setKibanaVariables (stream .Vars , config .DataStream .Vars )
583583 r .Inputs [0 ].Streams = streams
584584
585- // Add package-level vars
586- var inputVars []packages.Variable
585+ // Add input-level vars
587586 input := policyTemplate .FindInputByType (streamInput )
588587 if input != nil {
589- // copy package-level vars into each input
590- inputVars = append (inputVars , input .Vars ... )
591- inputVars = append (inputVars , pkg .Vars ... )
588+ r .Inputs [0 ].Vars = setKibanaVariables (input .Vars , config .Vars )
592589 }
593590
594- r .Inputs [0 ].Vars = setKibanaVariables (inputVars , config .Vars )
591+ // Add package-level vars
592+ r .Vars = setKibanaVariables (pkg .Vars , config .Vars )
595593
596594 return r
597595}
Original file line number Diff line number Diff line change 11# wait_for_data_timeout: 10m
22vars :
33 project_id : " {{GCP_PROJECT_ID}}"
4- zone : " {{GCP_ZONE}}"
54 credentials_json : ' {{{GOOGLE_CREDENTIALS}}}'
6- data_streams :
7- vars : ~
5+ data_stream :
6+ vars :
7+ zone : " {{GCP_ZONE}}"
8+ region : " {{GCP_REGION}}"
Original file line number Diff line number Diff line change 3232 multi : false
3333 required : true
3434 show_user : true
35- default : SET_PROJECT_NAME
3635 - name : credentials_file
3736 type : text
3837 title : Credentials File
You can’t perform that action at this time.
0 commit comments