@@ -166,7 +166,8 @@ func TestBuildPyFuncEnsemblerJobImage(t *testing.T) {
166
166
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
167
167
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
168
168
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
169
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
169
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
170
+ Return ([]byte (testCondaEnvContent ), nil )
170
171
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
171
172
},
172
173
},
@@ -235,7 +236,8 @@ func TestBuildPyFuncEnsemblerJobImage(t *testing.T) {
235
236
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
236
237
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
237
238
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
238
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
239
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
240
+ Return ([]byte (testCondaEnvContent ), nil )
239
241
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
240
242
},
241
243
},
@@ -328,7 +330,8 @@ func TestBuildPyFuncEnsemblerJobImage(t *testing.T) {
328
330
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
329
331
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
330
332
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
331
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
333
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
334
+ Return ([]byte (testCondaEnvContent ), nil )
332
335
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
333
336
},
334
337
},
@@ -471,7 +474,8 @@ func TestBuildPyFuncEnsemblerServiceImage(t *testing.T) {
471
474
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
472
475
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
473
476
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
474
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
477
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
478
+ Return ([]byte (testCondaEnvContent ), nil )
475
479
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
476
480
},
477
481
},
@@ -540,7 +544,8 @@ func TestBuildPyFuncEnsemblerServiceImage(t *testing.T) {
540
544
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
541
545
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
542
546
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
543
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
547
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
548
+ Return ([]byte (testCondaEnvContent ), nil )
544
549
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
545
550
},
546
551
},
@@ -633,7 +638,8 @@ func TestBuildPyFuncEnsemblerServiceImage(t *testing.T) {
633
638
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
634
639
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
635
640
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
636
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
641
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
642
+ Return ([]byte (testCondaEnvContent ), nil )
637
643
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
638
644
},
639
645
},
@@ -671,7 +677,8 @@ func TestBuildPyFuncEnsemblerServiceImage(t *testing.T) {
671
677
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
672
678
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
673
679
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
674
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
680
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
681
+ Return ([]byte (testCondaEnvContent ), nil )
675
682
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
676
683
},
677
684
},
@@ -852,7 +859,8 @@ func TestGetEnsemblerJobImageBuildingJobStatus(t *testing.T) {
852
859
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
853
860
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
854
861
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
855
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
862
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
863
+ Return ([]byte (testCondaEnvContent ), nil )
856
864
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
857
865
},
858
866
},
@@ -879,7 +887,8 @@ func TestGetEnsemblerJobImageBuildingJobStatus(t *testing.T) {
879
887
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
880
888
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
881
889
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
882
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
890
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
891
+ Return ([]byte (testCondaEnvContent ), nil )
883
892
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
884
893
},
885
894
},
@@ -967,7 +976,8 @@ CondaEnvException: Pip failed`,
967
976
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
968
977
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
969
978
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
970
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
979
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
980
+ Return ([]byte (testCondaEnvContent ), nil )
971
981
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
972
982
},
973
983
},
@@ -996,7 +1006,8 @@ CondaEnvException: Pip failed`,
996
1006
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
997
1007
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
998
1008
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
999
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1009
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1010
+ Return ([]byte (testCondaEnvContent ), nil )
1000
1011
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
1001
1012
},
1002
1013
},
@@ -1020,7 +1031,8 @@ CondaEnvException: Pip failed`,
1020
1031
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
1021
1032
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1022
1033
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1023
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1034
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1035
+ Return ([]byte (testCondaEnvContent ), nil )
1024
1036
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
1025
1037
},
1026
1038
},
@@ -1098,7 +1110,8 @@ func TestGetEnsemblerServiceImageBuildingJobStatus(t *testing.T) {
1098
1110
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
1099
1111
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1100
1112
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1101
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1113
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1114
+ Return ([]byte (testCondaEnvContent ), nil )
1102
1115
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
1103
1116
},
1104
1117
},
@@ -1125,7 +1138,8 @@ func TestGetEnsemblerServiceImageBuildingJobStatus(t *testing.T) {
1125
1138
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
1126
1139
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1127
1140
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1128
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1141
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1142
+ Return ([]byte (testCondaEnvContent ), nil )
1129
1143
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
1130
1144
},
1131
1145
},
@@ -1181,7 +1195,8 @@ func TestGetEnsemblerServiceImageBuildingJobStatus(t *testing.T) {
1181
1195
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
1182
1196
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1183
1197
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1184
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1198
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1199
+ Return ([]byte (testCondaEnvContent ), nil )
1185
1200
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
1186
1201
},
1187
1202
},
@@ -1233,7 +1248,8 @@ func TestGetEnsemblerServiceImageBuildingJobStatus(t *testing.T) {
1233
1248
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
1234
1249
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1235
1250
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1236
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1251
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1252
+ Return ([]byte (testCondaEnvContent ), nil )
1237
1253
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
1238
1254
},
1239
1255
},
@@ -1280,7 +1296,8 @@ func TestGetEnsemblerServiceImageBuildingJobStatus(t *testing.T) {
1280
1296
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
1281
1297
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1282
1298
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1283
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1299
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1300
+ Return ([]byte (testCondaEnvContent ), nil )
1284
1301
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
1285
1302
},
1286
1303
},
@@ -1355,7 +1372,8 @@ func TestDeleteEnsemblerJobImageBuildingJob(t *testing.T) {
1355
1372
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
1356
1373
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1357
1374
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1358
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1375
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1376
+ Return ([]byte (testCondaEnvContent ), nil )
1359
1377
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
1360
1378
},
1361
1379
},
@@ -1434,7 +1452,8 @@ func TestDeleteEnsemblerServiceImageBuildingJob(t *testing.T) {
1434
1452
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
1435
1453
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1436
1454
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1437
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1455
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1456
+ Return ([]byte (testCondaEnvContent ), nil )
1438
1457
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
1439
1458
},
1440
1459
},
@@ -1485,7 +1504,8 @@ func Test_imageBuilder_getHashedModelDependenciesUrl(t *testing.T) {
1485
1504
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
1486
1505
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1487
1506
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1488
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1507
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1508
+ Return ([]byte (testCondaEnvContent ), nil )
1489
1509
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return ([]byte (testCondaEnvContent ), nil )
1490
1510
},
1491
1511
want : modelDependenciesURL ,
@@ -1501,9 +1521,11 @@ func Test_imageBuilder_getHashedModelDependenciesUrl(t *testing.T) {
1501
1521
artifactServiceMock .On ("ParseURL" , fmt .Sprintf ("gs%s" , testArtifactURISuffix )).Return (testArtifactGsutilURL , nil )
1502
1522
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1503
1523
artifactServiceMock .On ("GetURLScheme" ).Return ("gs" )
1504
- artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).Return ([]byte (testCondaEnvContent ), nil )
1524
+ artifactServiceMock .On ("ReadArtifact" , mock .Anything , fmt .Sprintf ("gs%s" , testCondaEnvUrlSuffix )).
1525
+ Return ([]byte (testCondaEnvContent ), nil )
1505
1526
artifactServiceMock .On ("ReadArtifact" , mock .Anything , modelDependenciesURL ).Return (nil , artifact .ErrObjectNotExist )
1506
- artifactServiceMock .On ("WriteArtifact" , mock .Anything , modelDependenciesURL , []byte (testCondaEnvContent )).Return (nil )
1527
+ artifactServiceMock .On ("WriteArtifact" , mock .Anything , modelDependenciesURL , []byte (testCondaEnvContent )).
1528
+ Return (nil )
1507
1529
},
1508
1530
want : modelDependenciesURL ,
1509
1531
wantErr : false ,
0 commit comments