@@ -483,22 +483,22 @@ def _supplementary_bundle(self, bundle_fqid: TDRAnvilBundleFQID) -> TDRAnvilBund
483
483
484
484
def _duos_bundle (self , bundle_fqid : TDRAnvilBundleFQID ) -> TDRAnvilBundle :
485
485
assert not bundle_fqid .is_batched , bundle_fqid
486
- duos_id , duos_info = self .tdr .get_duos (bundle_fqid .source )
487
- description = None if duos_info is None else duos_info .get ('studyDescription' )
488
486
ref , row = self ._get_dataset (bundle_fqid .source .spec )
489
487
expected_entity_id = change_version (bundle_fqid .uuid ,
490
488
self .bundle_uuid_version ,
491
489
self .datarepo_row_uuid_version )
492
490
assert ref .entity_id == expected_entity_id , (ref , bundle_fqid )
493
491
bundle = TDRAnvilBundle (fqid = bundle_fqid )
494
- entity_row = {
495
- 'duos_id' : duos_id ,
496
- 'description' : description ,
497
- 'dataset_id' : row ['dataset_id' ]
498
- }
499
- bundle .add_entity (ref , self ._version , entity_row )
500
492
# Classify as orphan to suppress the emission of a contribution
501
493
bundle .add_entity (ref , self ._version , dict (row ), is_orphan = True )
494
+ duos_id , duos_info = self .tdr .get_duos (bundle_fqid .source )
495
+ if duos_id is not None :
496
+ entity_row = {
497
+ 'duos_id' : duos_id ,
498
+ 'description' : duos_info .get ('studyDescription' ),
499
+ 'dataset_id' : row ['dataset_id' ]
500
+ }
501
+ bundle .add_entity (ref , self ._version , entity_row )
502
502
return bundle
503
503
504
504
def _replica_bundle (self , bundle_fqid : TDRAnvilBundleFQID ) -> TDRAnvilBundle :
0 commit comments