@@ -147,31 +147,28 @@ describe('workflow-helper', () => {
147
147
apiVersion : 'argoproj.io/v1alpha1' ,
148
148
kind : 'Workflow' ,
149
149
status : {
150
+ artifactRepositoryRef : {
151
+ artifactRepository : {
152
+ archiveLogs : true ,
153
+ s3 : {
154
+ accessKeySecret : { key : 'accessKey' , name : 'accessKeyName' } ,
155
+ bucket : 'bucket' ,
156
+ endpoint : 'minio-service.kubeflow' ,
157
+ insecure : true ,
158
+ key :
159
+ 'prefix/workflow-name/workflow-name-system-container-impl-abc/some-artifact.csv' ,
160
+ secretKeySecret : { key : 'secretKey' , name : 'secretKeyName' } ,
161
+ } ,
162
+ } ,
163
+ } ,
150
164
nodes : {
151
165
'workflow-name-abc' : {
152
166
outputs : {
153
167
artifacts : [
154
168
{
155
- name : 'some-artifact.csv' ,
156
- s3 : {
157
- accessKeySecret : { key : 'accessKey' , name : 'accessKeyName' } ,
158
- bucket : 'bucket' ,
159
- endpoint : 'minio-service.kubeflow' ,
160
- insecure : true ,
161
- key : 'prefix/workflow-name/workflow-name-abc/some-artifact.csv' ,
162
- secretKeySecret : { key : 'secretKey' , name : 'secretKeyName' } ,
163
- } ,
164
- } ,
165
- {
166
- archiveLogs : true ,
167
- name : 'main.log' ,
169
+ name : 'main-logs' ,
168
170
s3 : {
169
- accessKeySecret : { key : 'accessKey' , name : 'accessKeyName' } ,
170
- bucket : 'bucket' ,
171
- endpoint : 'minio-service.kubeflow' ,
172
- insecure : true ,
173
- key : 'prefix/workflow-name/workflow-name-abc/main.log' ,
174
- secretKeySecret : { key : 'secretKey' , name : 'secretKeyName' } ,
171
+ key : 'prefix/workflow-name/workflow-name-system-container-impl-abc/main.log' ,
175
172
} ,
176
173
} ,
177
174
] ,
@@ -193,7 +190,10 @@ describe('workflow-helper', () => {
193
190
mockedClientGetObject . mockResolvedValueOnce ( objStream ) ;
194
191
objStream . end ( 'some fake logs.' ) ;
195
192
196
- const stream = await getPodLogsStreamFromWorkflow ( 'workflow-name-abc' , '2024-07-09' ) ;
193
+ const stream = await getPodLogsStreamFromWorkflow (
194
+ 'workflow-name-system-container-impl-abc' ,
195
+ '2024-07-09' ,
196
+ ) ;
197
197
198
198
expect ( mockedGetArgoWorkflow ) . toBeCalledWith ( 'workflow-name' ) ;
199
199
@@ -212,7 +212,7 @@ describe('workflow-helper', () => {
212
212
expect ( mockedClientGetObject ) . toBeCalledTimes ( 1 ) ;
213
213
expect ( mockedClientGetObject ) . toBeCalledWith (
214
214
'bucket' ,
215
- 'prefix/workflow-name/workflow-name-abc/main.log' ,
215
+ 'prefix/workflow-name/workflow-name-system-container-impl- abc/main.log' ,
216
216
) ;
217
217
} ) ;
218
218
} ) ;
0 commit comments