@@ -58,16 +58,16 @@ func (m *artifactManager) CreateArtifact(ctx context.Context, request *datacatal
58
58
timer := m .systemMetrics .createResponseTime .Start (ctx )
59
59
defer timer .Stop ()
60
60
61
- artifact := request .Artifact
61
+ artifact := request .GetArtifact ()
62
62
err := validators .ValidateArtifact (artifact )
63
63
if err != nil {
64
64
logger .Warningf (ctx , "Invalid create artifact request %v, err: %v" , request , err )
65
65
m .systemMetrics .validationErrorCounter .Inc (ctx )
66
66
return nil , err
67
67
}
68
68
69
- ctx = contextutils .WithProjectDomain (ctx , artifact .Dataset . Project , artifact .Dataset . Domain )
70
- datasetKey := transformers .FromDatasetID (artifact .Dataset )
69
+ ctx = contextutils .WithProjectDomain (ctx , artifact .GetDataset (). GetProject () , artifact .GetDataset (). GetDomain () )
70
+ datasetKey := transformers .FromDatasetID (artifact .GetDataset () )
71
71
72
72
// The dataset must exist for the artifact, let's verify that first
73
73
dataset , err := m .repo .DatasetRepo ().Get (ctx , datasetKey )
@@ -80,29 +80,29 @@ func (m *artifactManager) CreateArtifact(ctx context.Context, request *datacatal
80
80
// TODO: when adding a tag, need to verify one tag per partition combo
81
81
// check that the artifact's partitions are the same partition values of the dataset
82
82
datasetPartitionKeys := transformers .FromPartitionKeyModel (dataset .PartitionKeys )
83
- err = validators .ValidatePartitions (datasetPartitionKeys , artifact .Partitions )
83
+ err = validators .ValidatePartitions (datasetPartitionKeys , artifact .GetPartitions () )
84
84
if err != nil {
85
- logger .Warnf (ctx , "Invalid artifact partitions %v, err: %+v" , artifact .Partitions , err )
85
+ logger .Warnf (ctx , "Invalid artifact partitions %v, err: %+v" , artifact .GetPartitions () , err )
86
86
m .systemMetrics .createFailureCounter .Inc (ctx )
87
87
return nil , err
88
88
}
89
89
90
90
// create Artifact Data offloaded storage files
91
- artifactDataModels := make ([]models.ArtifactData , len (request .Artifact . Data ))
92
- for i , artifactData := range request .Artifact . Data {
91
+ artifactDataModels := make ([]models.ArtifactData , len (request .GetArtifact (). GetData () ))
92
+ for i , artifactData := range request .GetArtifact (). GetData () {
93
93
dataLocation , err := m .artifactStore .PutData (ctx , artifact , artifactData )
94
94
if err != nil {
95
95
logger .Errorf (ctx , "Failed to store artifact data err: %v" , err )
96
96
m .systemMetrics .createDataFailureCounter .Inc (ctx )
97
97
return nil , err
98
98
}
99
99
100
- artifactDataModels [i ].Name = artifactData .Name
100
+ artifactDataModels [i ].Name = artifactData .GetName ()
101
101
artifactDataModels [i ].Location = dataLocation .String ()
102
102
m .systemMetrics .createDataSuccessCounter .Inc (ctx )
103
103
}
104
104
105
- logger .Debugf (ctx , "Stored %v data for artifact %+v" , len (artifactDataModels ), artifact .Id )
105
+ logger .Debugf (ctx , "Stored %v data for artifact %+v" , len (artifactDataModels ), artifact .GetId () )
106
106
107
107
artifactModel , err := transformers .CreateArtifactModel (request , artifactDataModels , dataset )
108
108
if err != nil {
@@ -114,7 +114,7 @@ func (m *artifactManager) CreateArtifact(ctx context.Context, request *datacatal
114
114
err = m .repo .ArtifactRepo ().Create (ctx , artifactModel )
115
115
if err != nil {
116
116
if errors .IsAlreadyExistsError (err ) {
117
- logger .Warnf (ctx , "Artifact already exists key: %+v, err %v" , artifact .Id , err )
117
+ logger .Warnf (ctx , "Artifact already exists key: %+v, err %v" , artifact .GetId () , err )
118
118
m .systemMetrics .alreadyExistsCounter .Inc (ctx )
119
119
} else {
120
120
logger .Errorf (ctx , "Failed to create artifact %v, err: %v" , artifactDataModels , err )
@@ -123,7 +123,7 @@ func (m *artifactManager) CreateArtifact(ctx context.Context, request *datacatal
123
123
return nil , err
124
124
}
125
125
126
- logger .Debugf (ctx , "Successfully created artifact id: %v" , artifact .Id )
126
+ logger .Debugf (ctx , "Successfully created artifact id: %v" , artifact .GetId () )
127
127
128
128
m .systemMetrics .createSuccessCounter .Inc (ctx )
129
129
return & datacatalog.CreateArtifactResponse {}, nil
@@ -141,7 +141,7 @@ func (m *artifactManager) GetArtifact(ctx context.Context, request *datacatalog.
141
141
return nil , err
142
142
}
143
143
144
- datasetID := request .Dataset
144
+ datasetID := request .GetDataset ()
145
145
146
146
artifactModel , err := m .findArtifact (ctx , datasetID , request )
147
147
if err != nil {
@@ -164,7 +164,7 @@ func (m *artifactManager) GetArtifact(ctx context.Context, request *datacatalog.
164
164
}
165
165
artifact .Data = artifactDataList
166
166
167
- logger .Debugf (ctx , "Retrieved artifact dataset %v, id: %v" , artifact .Dataset , artifact .Id )
167
+ logger .Debugf (ctx , "Retrieved artifact dataset %v, id: %v" , artifact .GetDataset () , artifact .GetId () )
168
168
m .systemMetrics .getSuccessCounter .Inc (ctx )
169
169
return & datacatalog.GetArtifactResponse {
170
170
Artifact : artifact ,
@@ -249,7 +249,7 @@ func (m *artifactManager) ListArtifacts(ctx context.Context, request *datacatalo
249
249
}
250
250
251
251
// Verify the dataset exists before listing artifacts
252
- datasetKey := transformers .FromDatasetID (request .Dataset )
252
+ datasetKey := transformers .FromDatasetID (request .GetDataset () )
253
253
dataset , err := m .repo .DatasetRepo ().Get (ctx , datasetKey )
254
254
if err != nil {
255
255
logger .Warnf (ctx , "Failed to get dataset for listing artifacts %v, err: %v" , datasetKey , err )
@@ -265,7 +265,7 @@ func (m *artifactManager) ListArtifacts(ctx context.Context, request *datacatalo
265
265
return nil , err
266
266
}
267
267
268
- err = transformers .ApplyPagination (request .Pagination , & listInput )
268
+ err = transformers .ApplyPagination (request .GetPagination () , & listInput )
269
269
if err != nil {
270
270
logger .Warningf (ctx , "Invalid pagination options in list artifact request %v, err: %v" , request , err )
271
271
m .systemMetrics .validationErrorCounter .Inc (ctx )
@@ -311,7 +311,7 @@ func (m *artifactManager) ListArtifacts(ctx context.Context, request *datacatalo
311
311
// stored data will be overwritten in the underlying blob storage, no longer existing data (based on ArtifactData name)
312
312
// will be deleted.
313
313
func (m * artifactManager ) UpdateArtifact (ctx context.Context , request * datacatalog.UpdateArtifactRequest ) (* datacatalog.UpdateArtifactResponse , error ) {
314
- ctx = contextutils .WithProjectDomain (ctx , request .Dataset . Project , request .Dataset . Domain )
314
+ ctx = contextutils .WithProjectDomain (ctx , request .GetDataset (). GetProject () , request .GetDataset (). GetDomain () )
315
315
316
316
timer := m .systemMetrics .updateResponseTime .Start (ctx )
317
317
defer timer .Stop ()
@@ -333,9 +333,9 @@ func (m *artifactManager) UpdateArtifact(ctx context.Context, request *datacatal
333
333
}
334
334
335
335
// artifactModel needs to be updated with new SerializedMetadata
336
- serializedMetadata , err := transformers .SerializedMetadata (request .Metadata )
336
+ serializedMetadata , err := transformers .SerializedMetadata (request .GetMetadata () )
337
337
if err != nil {
338
- logger .Errorf (ctx , "Error in transforming Metadata from request %+v, err %v" , request .Metadata , err )
338
+ logger .Errorf (ctx , "Error in transforming Metadata from request %+v, err %v" , request .GetMetadata () , err )
339
339
m .systemMetrics .transformerErrorCounter .Inc (ctx )
340
340
m .systemMetrics .updateFailureCounter .Inc (ctx )
341
341
return nil , err
@@ -353,9 +353,9 @@ func (m *artifactManager) UpdateArtifact(ctx context.Context, request *datacatal
353
353
// overwrite existing artifact data and upload new entries, building a map of artifact data names to remove
354
354
// deleted entries from the blob storage after the upload completed
355
355
artifactDataNames := make (map [string ]struct {})
356
- artifactDataModels := make ([]models.ArtifactData , len (request .Data ))
357
- for i , artifactData := range request .Data {
358
- artifactDataNames [artifactData .Name ] = struct {}{}
356
+ artifactDataModels := make ([]models.ArtifactData , len (request .GetData () ))
357
+ for i , artifactData := range request .GetData () {
358
+ artifactDataNames [artifactData .GetName () ] = struct {}{}
359
359
360
360
dataLocation , err := m .artifactStore .PutData (ctx , artifact , artifactData )
361
361
if err != nil {
@@ -365,7 +365,7 @@ func (m *artifactManager) UpdateArtifact(ctx context.Context, request *datacatal
365
365
return nil , err
366
366
}
367
367
368
- artifactDataModels [i ].Name = artifactData .Name
368
+ artifactDataModels [i ].Name = artifactData .GetName ()
369
369
artifactDataModels [i ].Location = dataLocation .String ()
370
370
m .systemMetrics .updateDataSuccessCounter .Inc (ctx )
371
371
}
@@ -384,7 +384,7 @@ func (m *artifactManager) UpdateArtifact(ctx context.Context, request *datacatal
384
384
err = m .repo .ArtifactRepo ().Update (ctx , artifactModel )
385
385
if err != nil {
386
386
if errors .IsDoesNotExistError (err ) {
387
- logger .Warnf (ctx , "Artifact does not exist key: %+v, err %v" , artifact .Id , err )
387
+ logger .Warnf (ctx , "Artifact does not exist key: %+v, err %v" , artifact .GetId () , err )
388
388
m .systemMetrics .doesNotExistCounter .Inc (ctx )
389
389
} else {
390
390
logger .Errorf (ctx , "Failed to update artifact %v, err: %v" , artifactModel , err )
@@ -408,11 +408,11 @@ func (m *artifactManager) UpdateArtifact(ctx context.Context, request *datacatal
408
408
m .systemMetrics .deleteDataSuccessCounter .Inc (ctx )
409
409
}
410
410
411
- logger .Debugf (ctx , "Successfully updated artifact id: %v" , artifact .Id )
411
+ logger .Debugf (ctx , "Successfully updated artifact id: %v" , artifact .GetId () )
412
412
413
413
m .systemMetrics .updateSuccessCounter .Inc (ctx )
414
414
return & datacatalog.UpdateArtifactResponse {
415
- ArtifactId : artifact .Id ,
415
+ ArtifactId : artifact .GetId () ,
416
416
}, nil
417
417
}
418
418
0 commit comments