@@ -99,6 +99,8 @@ def get_all(self, condition: Condition = None) -> List[ProjectEntity]:
9999
100100 def insert (self , entity : ProjectEntity ) -> ProjectEntity :
101101 project_data = self ._drop_nones (entity .to_dict ())
102+ if not project_data .get ("status" ):
103+ project_data ["status" ] = constance .ProjectStatus .NotStarted .value
102104 result = self ._service .create_project (project_data )
103105 return self .dict2entity (result )
104106
@@ -118,21 +120,21 @@ def delete(self, entity: ProjectEntity):
118120 )
119121
120122 @staticmethod
121- def dict2entity (data : dict ):
123+ def dict2entity (data : dict ) -> ProjectEntity :
122124 try :
123125 return ProjectEntity (
124126 uuid = data ["id" ],
125127 team_id = data ["team_id" ],
126128 name = data ["name" ],
127129 project_type = data ["type" ],
128- status = data [ "status" ] ,
129- attachment_name = data [ "attachment_name" ] ,
130- attachment_path = data [ "attachment_path" ] ,
131- entropy_status = data [ "entropy_status" ] ,
130+ status = data . get ( "status" ) ,
131+ attachment_name = data . get ( "attachment_name" ) ,
132+ attachment_path = data . get ( "attachment_path" ) ,
133+ entropy_status = data . get ( "entropy_status" ) ,
132134 sharing_status = data .get ("sharing_status" ),
133135 creator_id = data ["creator_id" ],
134136 upload_state = data ["upload_state" ],
135- description = data [ "description" ] ,
137+ description = data . get ( "description" ) ,
136138 folder_id = data .get ("folder_id" ),
137139 users = data .get ("users" , ()),
138140 unverified_users = data .get ("unverified_users" , ()),
@@ -148,6 +150,7 @@ def dict2entity(data: dict):
148150
149151
150152class S3Repository (BaseS3Repository ):
153+
151154 def get_one (self , uuid : str ) -> S3FileEntity :
152155 file = io .BytesIO ()
153156 self ._resource .Object (self ._bucket , uuid ).download_fileobj (file )
@@ -242,7 +245,7 @@ def update(self, entity: WorkflowEntity):
242245 raise NotImplementedError
243246
244247 @staticmethod
245- def dict2entity (data : dict ):
248+ def dict2entity (data : dict ) -> WorkflowEntity :
246249 return WorkflowEntity (
247250 uuid = data ["id" ],
248251 project_id = data ["project_id" ],
@@ -294,7 +297,7 @@ def bulk_delete(self, entities: List[FolderEntity]):
294297 return self ._service .delete_folders (entity .project_id , entity .team_id , ids )
295298
296299 @staticmethod
297- def dict2entity (data : dict ):
300+ def dict2entity (data : dict ) -> FolderEntity :
298301 try :
299302 return FolderEntity (
300303 uuid = data ["id" ],
@@ -397,7 +400,7 @@ def update(self, entity: ImageEntity):
397400 return entity
398401
399402 @staticmethod
400- def dict2entity (data : dict ):
403+ def dict2entity (data : dict ) -> ImageEntity :
401404 return ImageEntity (
402405 uuid = data ["id" ],
403406 name = data ["name" ],
@@ -416,7 +419,7 @@ def dict2entity(data: dict):
416419
417420class UserRepository (BaseReadOnlyRepository ):
418421 @staticmethod
419- def dict2entity (data : dict ):
422+ def dict2entity (data : dict ) -> UserEntity :
420423 return UserEntity (
421424 uuid = data ["id" ],
422425 first_name = data ["first_name" ],
@@ -480,7 +483,7 @@ def update(self, entity: MLModelEntity):
480483 return self .dict2entity (data )
481484
482485 @staticmethod
483- def dict2entity (data : dict ):
486+ def dict2entity (data : dict ) -> MLModelEntity :
484487 return MLModelEntity (
485488 uuid = data ["id" ],
486489 name = data ["name" ],
0 commit comments