I have a couple of threads that are working on the same objects, passing them back and forth in queues. I have just started testing with the Sqlalchemy parts turned on, and I am getting the already attached to session message. Also of note is that I am using the Elixir declarative layer, although I don't think that is causing the problem. Here is a basic example of what I am doing.
queue = Queue() class History(Entity): status_id = Field(Integer) text = Field(Text) using_options(tablename='history', autosetup=True) using_table_options(useexisting=True) class Worker(threading.Thread): def run(self): items = History.query.all() for item in item: queue.put(item) for i in range(pool_size): consumer = Consumer(self.getName()) consumer.start() class Consumer(threading.Thread): def run(self): item = queue.get_nowait() if True: item.status_id = 1 else: item.status_id = 2 item.update() item.flush() when I try to update I get: InvalidRequestError: Object '[EMAIL PROTECTED]' is already attached to session '21222960' (this is '21223440') any help would be greatly appreciated. thanks, Matt --~--~---------~--~----~------------~-------~--~----~ You received this message because you are subscribed to the Google Groups "sqlalchemy" group. To post to this group, send email to sqlalchemy@googlegroups.com To unsubscribe from this group, send email to [EMAIL PROTECTED] For more options, visit this group at http://groups.google.com/group/sqlalchemy?hl=en -~----------~----~----~----~------~----~------~--~---