cascade: fix watermark publishing
authorMarko Kreen <markokr@gmail.com>
Sat, 2 May 2009 11:47:39 +0000 (14:47 +0300)
committerMarko Kreen <markokr@gmail.com>
Sat, 2 May 2009 11:47:39 +0000 (14:47 +0300)
commit0801a025297e412cc142680798bdd01d2d887f88
tree3ae89c191c242cc9141dcbb78afe185ac6a29ca0
parent85c3fad753c3ff98b0f64aa0824c83bd1683e1b6
cascade: fix watermark publishing

* CascadedWorker:
  - fix time comparision in local wm handling
  - publish wm also for leaf nodes
  - fields node_type, node_name, local_watermark were missing in WorkerState
* pgq_node.get_node_info: on leaf node set local watermark to last consumer tick
* pgq_node.set_global_watermark: don't depend on exact code from pgq_node.get_node_info()

Trying to special-case leaf nodes does not seem to be good idea, because
then provider nodes also need to know subscriber node type.  So stop doing it.
python/pgq/cascade/worker.py
sql/pgq_node/functions/pgq_node.get_node_info.sql
sql/pgq_node/functions/pgq_node.set_global_watermark.sql