206         self.session.commit()

   206         self.session.commit()

   207         self.session.set_pool()

   207         self.session.set_pool()

   208 

   208 

   209 

   209 

   210 class BasePlannerTC(BaseQuerierTC):

   210 class BasePlannerTC(BaseQuerierTC):

   211     def setup(self):

   212     def setup(self):

   212         clear_cache(self.repo, 'rel_type_sources')

   213         clear_cache(self.repo, 'rel_type_sources')

   213         clear_cache(self.repo, 'rel_type_sources')

   214         clear_cache(self.repo, 'rel_type_sources')

   214         clear_cache(self.repo, 'can_cross_relation')

   215         clear_cache(self.repo, 'can_cross_relation')

   215         clear_cache(self.repo, 'is_multi_sources_relation')

   216         clear_cache(self.repo, 'is_multi_sources_relation')

   218         self.session = self.repo._sessions.values()[0]

   219         self.session = self.repo._sessions.values()[0]

   219         self.pool = self.session.set_pool()

   220         self.pool = self.session.set_pool()

   220         self.schema = self.o.schema

   221         self.schema = self.o.schema

   221         self.sources = self.o._repo.sources

   222         self.sources = self.o._repo.sources

   222         self.system = self.sources[-1]

   223         self.system = self.sources[-1]

   224         do_monkey_patch()

   224         do_monkey_patch()

   225 

   225 

   226     def add_source(self, sourcecls, uri):

   226     def add_source(self, sourcecls, uri):

   227         self.sources.append(sourcecls(self.repo, self.o.schema,

   227         self.sources.append(sourcecls(self.repo, self.o.schema,

   228                                       {'uri': uri}))

   228                                       {'uri': uri}))