- [ self.locate_by_type_pointer ('user',user_id) for user_id in slice['person_ids'] ]
- dbsession.commit()
- slice_record.stale=False
-
- ### remove stale records
+ [self.locate_by_type_pointer('user', user_id) for user_id in slice[
+ 'person_ids']]
+ # remove any weird value (looks like we can get 'None' here
+ slice_record.reg_researchers = [
+ x for x in slice_record.reg_researchers if x]
+ global_dbsession.commit()
+ slice_record.stale = False
+
+ # Set PL Admins as PI's of the top authority
+ if admins:
+ top_auth_record.reg_pis = list(set(admins))
+ global_dbsession.commit()
+ self.logger.info('PlImporter: set PL admins {} as PIs of {}'
+ .format(admins, top_auth_record.hrn))
+
+ # remove stale records