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
-~----------~----~----~----~------~----~------~--~---

Reply via email to