equal
deleted
inserted
replaced
900 """ |
900 """ |
901 def task(): |
901 def task(): |
902 session = self._get_session(sessionid, setcnxset=True) |
902 session = self._get_session(sessionid, setcnxset=True) |
903 service = session.vreg['services'].select(regid, session, **kwargs) |
903 service = session.vreg['services'].select(regid, session, **kwargs) |
904 try: |
904 try: |
905 return service.call(session, **kwargs) |
905 return service.call(**kwargs) |
906 finally: |
906 finally: |
907 session.rollback() # free cnxset |
907 session.rollback() # free cnxset |
908 if async: |
908 if async: |
909 self.info('calling service %s asynchronously', regid) |
909 self.info('calling service %s asynchronously', regid) |
910 self.threaded_task(task) |
910 self.threaded_task(task) |