CascadedWorker: call pgq_node.set_global_watermark() only on branch
authorMarko Kreen <markokr@gmail.com>
Wed, 26 Jan 2011 14:54:26 +0000 (16:54 +0200)
committerMarko Kreen <markokr@gmail.com>
Wed, 26 Jan 2011 14:54:26 +0000 (16:54 +0200)
commitf79ea267ea50bb227f74f435dd9bd3f6820215ac
tree5b3e9dcf873d7003105d696d9f92ef42dc25eb9b
parentdbe6598f4e6baa55fbccbf558020d6000db16f4f
CascadedWorker: call pgq_node.set_global_watermark() only on branch
python/pgq/cascade/worker.py