session = DBConn().session().object_session(self)
# Remove changes_pool_files entries
- for pf in self.poolfiles:
- self.poolfiles.remove(pf)
+ self.poolfiles = []
- # Remove change
- for cf in self.files:
- self.files.remove(cf)
+ # Remove changes_pending_files references
+ self.files = []
# Clear out of queue
self.in_queue = None
session.flush()
- return dsc_component, dsc_location_id, pfs
+ return source, dsc_component, dsc_location_id, pfs
__all__.append('add_dsc_to_db')