server/sources/datafeed.py
branchstable
changeset 7699 d07cde311630
parent 7698 1c7411535c2d
child 7708 45be3a9debe6
equal deleted inserted replaced
7698:1c7411535c2d 7699:d07cde311630
   266         """
   266         """
   267         session = self._cw
   267         session = self._cw
   268         # if cwsource is specified and repository has a source with the same
   268         # if cwsource is specified and repository has a source with the same
   269         # name, call extid2eid on that source so entity will be properly seen as
   269         # name, call extid2eid on that source so entity will be properly seen as
   270         # coming from this source
   270         # coming from this source
   271         source = session.repo.sources_by_uri.get(
   271         source_uri = sourceparams.pop('cwsource', None)
   272             sourceparams.pop('cwsource', None), self.source)
   272         if source_uri is not None and source_uri != 'system':
       
   273             source = session.repo.sources_by_uri.get(source_uri, self.source)
       
   274         else:
       
   275             source = self.source
   273         sourceparams['parser'] = self
   276         sourceparams['parser'] = self
   274         try:
   277         try:
   275             eid = session.repo.extid2eid(source, str(uri), etype, session,
   278             eid = session.repo.extid2eid(source, str(uri), etype, session,
   276                                          complete=False,
   279                                          complete=False,
   277                                          sourceparams=sourceparams)
   280                                          sourceparams=sourceparams)