404             if self.repo.config.init_cnxset_pool:

   404             if self.repo.config.init_cnxset_pool:

   405                 self.open_source_connections()

   405                 self.open_source_connections()

   406 

   406 

   407 

   407 

   408     def init(self, activated, source_entity):

   408     def init(self, activated, source_entity):

   409         self.init_creating(source_entity._cw.cnxset)

   410         self.init_creating(source_entity._cw.cnxset)

   410         try:

   411         try:

   411             # test if 'asource' column exists

   412             # test if 'asource' column exists

   412             query = self.dbhelper.sql_add_limit_offset('SELECT asource FROM entities', 1)

   413             query = self.dbhelper.sql_add_limit_offset('SELECT asource FROM entities', 1)

   413             source_entity._cw.system_sql(query)

   414             source_entity._cw.system_sql(query)