allen.fowler wrote: > > > > Quick questions: > How doe this code handle transactions?
engine.execute() is an "autocommit" method. the SQL expression is executed in a new transaction which is immediately committed. > Where in the code does it atomically assign a task to a worker without > making a race condition? (Or does it?) there is an update() statement which assigns the current process ID to rows which do not already have one and have not been marked as "completed". its a single statement which should execute atomically, and the transaction is committed immediately. once they are marked only that process will access them. --~--~---------~--~----~------------~-------~--~----~ 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 sqlalchemy+unsubscr...@googlegroups.com For more options, visit this group at http://groups.google.com/group/sqlalchemy?hl=en -~----------~----~----~----~------~----~------~--~---