code: def complete_transfer(self, relation, cleanup=True):
      
      relation.completed_at = utc_now().isoformat()
      self.data_access.update_model(relation)
      if cleanup:
        self.cleanup()
      return relation
docs: Write records to the data source indicating that a transfer has been completed for a
      particular relation.