Skip to content

Commit 812a2ac

Browse files
authored
feat(cli): remap field type names on cm package upload (#406)
1 parent 466a60c commit 812a2ac

File tree

2 files changed

+21
-5
lines changed

2 files changed

+21
-5
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
# Unreleased
22
- Only ask for ai unit consumpion consent when unpacking CM packages
3+
- Remap entity field type names on cm package upload
34

45
# v0.38.7
56
- Add `--attachments` to get comment

cli/src/commands/package/upload.rs

Lines changed: 20 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,12 @@ use reinfer_client::{
1919
resources::{
2020
bucket::{Bucket, Id as BucketId},
2121
dataset::{DatasetFlag, IxpDatasetNew, ModelConfig},
22-
entity_def::{EntityRuleSetNew, FieldChoiceNew, NewGeneralFieldDef},
22+
entity_def::{EntityRuleSetNew, FieldChoiceNew, Name as EntityDefName, NewGeneralFieldDef},
2323
},
24-
Client, CommentUid, Dataset, DatasetFullName, DatasetName, LabelDef, NewAnnotatedComment,
25-
NewBucket, NewComment, NewDataset, NewEntityDef, NewLabelDef, NewLabelDefPretrained, NewSource,
26-
ProjectName, Source, SourceId, SourceKind, UpdateDataset, Username, DEFAULT_LABEL_GROUP_NAME,
24+
Client, CommentUid, Dataset, DatasetFullName, DatasetName, EntityDefId, LabelDef,
25+
NewAnnotatedComment, NewBucket, NewComment, NewDataset, NewEntityDef, NewLabelDef,
26+
NewLabelDefPretrained, NewSource, ProjectName, Source, SourceId, SourceKind, UpdateDataset,
27+
Username, DEFAULT_LABEL_GROUP_NAME,
2728
};
2829
use scoped_threadpool::Pool;
2930
use structopt::StructOpt;
@@ -489,6 +490,13 @@ fn unpack_cm_dataset(
489490
packaged_dataset.owner = new_project_name.to_username();
490491
}
491492

493+
let entify_def_id_to_name: HashMap<EntityDefId, EntityDefName> = packaged_dataset
494+
.entity_defs
495+
.clone()
496+
.into_iter()
497+
.map(|def| (def.id, def.name))
498+
.collect();
499+
492500
match client.get_dataset(packaged_dataset.full_name()) {
493501
Ok(dataset) => Ok(dataset),
494502
Err(_) => {
@@ -535,7 +543,14 @@ fn unpack_cm_dataset(
535543
.map(|def| NewGeneralFieldDef {
536544
api_name: def.api_name.clone(),
537545
field_type_id: def.field_type_id.clone(),
538-
field_type_name: def.field_type_name.clone(),
546+
field_type_name: if let Some(field_type_id) = &def.field_type_id
547+
{
548+
entify_def_id_to_name
549+
.get(&EntityDefId(field_type_id.clone()))
550+
.cloned()
551+
} else {
552+
None
553+
},
539554
})
540555
.collect::<Vec<NewGeneralFieldDef>>(),
541556
),

0 commit comments

Comments
 (0)