@@ -21,10 +21,10 @@ class InferencePipelineDataStreamParamsTest {
21
21
.costColumnName(" cost" )
22
22
.groundTruthColumnName(" ground_truth" )
23
23
.inferenceIdColumnName(" id" )
24
- .inputVariableNames(listOf (" string " ))
24
+ .inputVariableNames(listOf (" user_query " ))
25
25
.latencyColumnName(" latency" )
26
26
.metadata(JsonValue .from(mapOf<String , Any >()))
27
- .numOfTokenColumnName(" num_tokens " )
27
+ .numOfTokenColumnName(" tokens " )
28
28
.prompt(
29
29
listOf (
30
30
InferencePipelineDataStreamParams .Config .LlmData .Prompt .builder()
@@ -38,7 +38,17 @@ class InferencePipelineDataStreamParamsTest {
38
38
.build()
39
39
)
40
40
)
41
- .rows(listOf (InferencePipelineDataStreamParams .Row .builder().build()))
41
+ .rows(
42
+ listOf (
43
+ InferencePipelineDataStreamParams .Row .builder()
44
+ .putAdditionalProperty(" user_query" , JsonValue .from(" bar" ))
45
+ .putAdditionalProperty(" output" , JsonValue .from(" bar" ))
46
+ .putAdditionalProperty(" tokens" , JsonValue .from(" bar" ))
47
+ .putAdditionalProperty(" cost" , JsonValue .from(" bar" ))
48
+ .putAdditionalProperty(" timestamp" , JsonValue .from(" bar" ))
49
+ .build()
50
+ )
51
+ )
42
52
.build()
43
53
}
44
54
@@ -55,10 +65,10 @@ class InferencePipelineDataStreamParamsTest {
55
65
.costColumnName(" cost" )
56
66
.groundTruthColumnName(" ground_truth" )
57
67
.inferenceIdColumnName(" id" )
58
- .inputVariableNames(listOf (" string " ))
68
+ .inputVariableNames(listOf (" user_query " ))
59
69
.latencyColumnName(" latency" )
60
70
.metadata(JsonValue .from(mapOf<String , Any >()))
61
- .numOfTokenColumnName(" num_tokens " )
71
+ .numOfTokenColumnName(" tokens " )
62
72
.prompt(
63
73
listOf (
64
74
InferencePipelineDataStreamParams .Config .LlmData .Prompt
@@ -73,7 +83,17 @@ class InferencePipelineDataStreamParamsTest {
73
83
.build()
74
84
)
75
85
)
76
- .rows(listOf (InferencePipelineDataStreamParams .Row .builder().build()))
86
+ .rows(
87
+ listOf (
88
+ InferencePipelineDataStreamParams .Row .builder()
89
+ .putAdditionalProperty(" user_query" , JsonValue .from(" bar" ))
90
+ .putAdditionalProperty(" output" , JsonValue .from(" bar" ))
91
+ .putAdditionalProperty(" tokens" , JsonValue .from(" bar" ))
92
+ .putAdditionalProperty(" cost" , JsonValue .from(" bar" ))
93
+ .putAdditionalProperty(" timestamp" , JsonValue .from(" bar" ))
94
+ .build()
95
+ )
96
+ )
77
97
.build()
78
98
val body = params.getBody()
79
99
assertThat(body).isNotNull
@@ -86,10 +106,10 @@ class InferencePipelineDataStreamParamsTest {
86
106
.costColumnName(" cost" )
87
107
.groundTruthColumnName(" ground_truth" )
88
108
.inferenceIdColumnName(" id" )
89
- .inputVariableNames(listOf (" string " ))
109
+ .inputVariableNames(listOf (" user_query " ))
90
110
.latencyColumnName(" latency" )
91
111
.metadata(JsonValue .from(mapOf<String , Any >()))
92
- .numOfTokenColumnName(" num_tokens " )
112
+ .numOfTokenColumnName(" tokens " )
93
113
.prompt(
94
114
listOf (
95
115
InferencePipelineDataStreamParams .Config .LlmData .Prompt .builder()
@@ -104,7 +124,17 @@ class InferencePipelineDataStreamParamsTest {
104
124
)
105
125
)
106
126
assertThat(body.rows())
107
- .isEqualTo(listOf (InferencePipelineDataStreamParams .Row .builder().build()))
127
+ .isEqualTo(
128
+ listOf (
129
+ InferencePipelineDataStreamParams .Row .builder()
130
+ .putAdditionalProperty(" user_query" , JsonValue .from(" bar" ))
131
+ .putAdditionalProperty(" output" , JsonValue .from(" bar" ))
132
+ .putAdditionalProperty(" tokens" , JsonValue .from(" bar" ))
133
+ .putAdditionalProperty(" cost" , JsonValue .from(" bar" ))
134
+ .putAdditionalProperty(" timestamp" , JsonValue .from(" bar" ))
135
+ .build()
136
+ )
137
+ )
108
138
}
109
139
110
140
@Test
@@ -119,7 +149,17 @@ class InferencePipelineDataStreamParamsTest {
119
149
.build()
120
150
)
121
151
)
122
- .rows(listOf (InferencePipelineDataStreamParams .Row .builder().build()))
152
+ .rows(
153
+ listOf (
154
+ InferencePipelineDataStreamParams .Row .builder()
155
+ .putAdditionalProperty(" user_query" , JsonValue .from(" bar" ))
156
+ .putAdditionalProperty(" output" , JsonValue .from(" bar" ))
157
+ .putAdditionalProperty(" tokens" , JsonValue .from(" bar" ))
158
+ .putAdditionalProperty(" cost" , JsonValue .from(" bar" ))
159
+ .putAdditionalProperty(" timestamp" , JsonValue .from(" bar" ))
160
+ .build()
161
+ )
162
+ )
123
163
.build()
124
164
val body = params.getBody()
125
165
assertThat(body).isNotNull
@@ -132,7 +172,17 @@ class InferencePipelineDataStreamParamsTest {
132
172
)
133
173
)
134
174
assertThat(body.rows())
135
- .isEqualTo(listOf (InferencePipelineDataStreamParams .Row .builder().build()))
175
+ .isEqualTo(
176
+ listOf (
177
+ InferencePipelineDataStreamParams .Row .builder()
178
+ .putAdditionalProperty(" user_query" , JsonValue .from(" bar" ))
179
+ .putAdditionalProperty(" output" , JsonValue .from(" bar" ))
180
+ .putAdditionalProperty(" tokens" , JsonValue .from(" bar" ))
181
+ .putAdditionalProperty(" cost" , JsonValue .from(" bar" ))
182
+ .putAdditionalProperty(" timestamp" , JsonValue .from(" bar" ))
183
+ .build()
184
+ )
185
+ )
136
186
}
137
187
138
188
@Test
@@ -147,7 +197,17 @@ class InferencePipelineDataStreamParamsTest {
147
197
.build()
148
198
)
149
199
)
150
- .rows(listOf (InferencePipelineDataStreamParams .Row .builder().build()))
200
+ .rows(
201
+ listOf (
202
+ InferencePipelineDataStreamParams .Row .builder()
203
+ .putAdditionalProperty(" user_query" , JsonValue .from(" bar" ))
204
+ .putAdditionalProperty(" output" , JsonValue .from(" bar" ))
205
+ .putAdditionalProperty(" tokens" , JsonValue .from(" bar" ))
206
+ .putAdditionalProperty(" cost" , JsonValue .from(" bar" ))
207
+ .putAdditionalProperty(" timestamp" , JsonValue .from(" bar" ))
208
+ .build()
209
+ )
210
+ )
151
211
.build()
152
212
assertThat(params).isNotNull
153
213
// path param "inferencePipelineId"
0 commit comments