)]}'
{"doc/source/workers.rst":[{"author":{"_account_id":8895,"name":"Stanislav Kudriashev","email":"stas.kudriashev@gmail.com","username":"skudriashev"},"change_message_id":"fe791a6ece1d8c354e197fc1ba46316d477475bb","unresolved":false,"context_lines":[{"line_number":27,"context_line":"  run them via engines."},{"line_number":28,"context_line":""},{"line_number":29,"context_line":"Transport + protocol"},{"line_number":30,"context_line":"  Mechanism (and encoding ontop of that mechanism) used to pass information"},{"line_number":31,"context_line":"  between the client and worker (for example amqp as a transport and a json"},{"line_number":32,"context_line":"  encoded message format as the protocol)."},{"line_number":33,"context_line":""}],"source_content_type":"text/x-rst","patch_set":7,"id":"bad4c104_da3d85bd","line":30,"updated":"2014-04-29 07:52:50.000000000","message":"ontop -\u003e on top?","commit_id":"19710d9edba0871aa6e07c832691ffd3010c12fa"},{"author":{"_account_id":8895,"name":"Stanislav Kudriashev","email":"stas.kudriashev@gmail.com","username":"skudriashev"},"change_message_id":"fe791a6ece1d8c354e197fc1ba46316d477475bb","unresolved":false,"context_lines":[{"line_number":53,"context_line":"  *(local)* engines with minimal, if any refactoring (e.g. it should be"},{"line_number":54,"context_line":"  possible to run the same flows on it without changing client code if"},{"line_number":55,"context_line":"  everything is set up and configured properly)."},{"line_number":56,"context_line":"* **Transport-agnostic:** the means of transporint should be abstracted so that"},{"line_number":57,"context_line":"  we can use `oslo.messaging`_, `gearmand`_, `amqp`_, `zookeeper`_, `marconi`_,"},{"line_number":58,"context_line":"  `websockets`_ or anything else that allows for passing information between a"},{"line_number":59,"context_line":"  client and a worker."}],"source_content_type":"text/x-rst","patch_set":7,"id":"bad4c104_7a6e39cb","line":56,"updated":"2014-04-29 07:52:50.000000000","message":"transporint -\u003e transport?","commit_id":"19710d9edba0871aa6e07c832691ffd3010c12fa"},{"author":{"_account_id":8895,"name":"Stanislav Kudriashev","email":"stas.kudriashev@gmail.com","username":"skudriashev"},"change_message_id":"b66789dff5aa3a78b029453a64867132e4c39ac6","unresolved":false,"context_lines":[{"line_number":37,"context_line":""},{"line_number":38,"context_line":"Worker"},{"line_number":39,"context_line":"  Workers are started on remote hosts and has list of atoms it can perform."},{"line_number":40,"context_line":"  Workers accept and processes atom requests that are published by an executor."},{"line_number":41,"context_line":"  Several requests can be processed simultaneously in separate threads (for"},{"line_number":42,"context_line":"  example, an `executor`_ can be passed to the worker and configured to run in"},{"line_number":43,"context_line":"  as many threads as desired)."}],"source_content_type":"text/x-rst","patch_set":8,"id":"9ad9bd40_d809e896","line":40,"updated":"2014-05-01 12:15:19.000000000","message":"... accept and process ...","commit_id":"a0b37e5f69900aeb404f95564e49eef6bc049069"},{"author":{"_account_id":1297,"name":"Joshua Harlow","email":"jxharlow@godaddy.com","username":"harlowja"},"change_message_id":"b1ed09c24b453ececf2c13238db3842a817ea9e3","unresolved":false,"context_lines":[{"line_number":37,"context_line":""},{"line_number":38,"context_line":"Worker"},{"line_number":39,"context_line":"  Workers are started on remote hosts and has list of atoms it can perform."},{"line_number":40,"context_line":"  Workers accept and processes atom requests that are published by an executor."},{"line_number":41,"context_line":"  Several requests can be processed simultaneously in separate threads (for"},{"line_number":42,"context_line":"  example, an `executor`_ can be passed to the worker and configured to run in"},{"line_number":43,"context_line":"  as many threads as desired)."}],"source_content_type":"text/x-rst","patch_set":8,"id":"9ad9bd40_3502b10b","line":40,"in_reply_to":"9ad9bd40_d809e896","updated":"2014-05-02 22:16:14.000000000","message":"Done","commit_id":"a0b37e5f69900aeb404f95564e49eef6bc049069"},{"author":{"_account_id":8895,"name":"Stanislav Kudriashev","email":"stas.kudriashev@gmail.com","username":"skudriashev"},"change_message_id":"b66789dff5aa3a78b029453a64867132e4c39ac6","unresolved":false,"context_lines":[{"line_number":123,"context_line":"2. :py:class:`~taskflow.engines.worker_based.proxy.Proxy` publishes task"},{"line_number":124,"context_line":"   request (format is described below) into a named exchange using a routing"},{"line_number":125,"context_line":"   key that is used to deliver request to particular workers topic. The executor"},{"line_number":126,"context_line":"   then waits for the task request/s to be accepted and confirmed by workers. If"},{"line_number":127,"context_line":"   the executor doesn\u0027t get a task confirmation from workers within the given"},{"line_number":128,"context_line":"   timeout the task is considered as timed-out and a timeout exception is"},{"line_number":129,"context_line":"   raised."}],"source_content_type":"text/x-rst","patch_set":8,"id":"9ad9bd40_d8300859","line":126,"updated":"2014-05-01 12:15:19.000000000","message":"request/s -\u003e requests","commit_id":"a0b37e5f69900aeb404f95564e49eef6bc049069"},{"author":{"_account_id":1297,"name":"Joshua Harlow","email":"jxharlow@godaddy.com","username":"harlowja"},"change_message_id":"b1ed09c24b453ececf2c13238db3842a817ea9e3","unresolved":false,"context_lines":[{"line_number":123,"context_line":"2. :py:class:`~taskflow.engines.worker_based.proxy.Proxy` publishes task"},{"line_number":124,"context_line":"   request (format is described below) into a named exchange using a routing"},{"line_number":125,"context_line":"   key that is used to deliver request to particular workers topic. The executor"},{"line_number":126,"context_line":"   then waits for the task request/s to be accepted and confirmed by workers. If"},{"line_number":127,"context_line":"   the executor doesn\u0027t get a task confirmation from workers within the given"},{"line_number":128,"context_line":"   timeout the task is considered as timed-out and a timeout exception is"},{"line_number":129,"context_line":"   raised."}],"source_content_type":"text/x-rst","patch_set":8,"id":"9ad9bd40_15076d1d","line":126,"in_reply_to":"9ad9bd40_d8300859","updated":"2014-05-02 22:16:14.000000000","message":"Done","commit_id":"a0b37e5f69900aeb404f95564e49eef6bc049069"},{"author":{"_account_id":8895,"name":"Stanislav Kudriashev","email":"stas.kudriashev@gmail.com","username":"skudriashev"},"change_message_id":"b66789dff5aa3a78b029453a64867132e4c39ac6","unresolved":false,"context_lines":[{"line_number":310,"context_line":"  resource objects (database handles, file descriptors, sockets, ...) can **not**"},{"line_number":311,"context_line":"  be directly sent across to remote workers (instead the configuration that"},{"line_number":312,"context_line":"  defines how to fetch/create these objects must be instead)."},{"line_number":313,"context_line":"* Worker-based engines will in the future be able to run lightweight tasks"},{"line_number":314,"context_line":"  locally to avoid transport overhead for very simple tasks (currently it will"},{"line_number":315,"context_line":"  run even lightweight tasks remotely, which may be non-performant)."},{"line_number":316,"context_line":"* Fault detection, currently when a worker acknowledges a task the engine will"}],"source_content_type":"text/x-rst","patch_set":8,"id":"9ad9bd40_d81728a2","line":313,"updated":"2014-05-01 12:15:19.000000000","message":"engines -\u003e engine?","commit_id":"a0b37e5f69900aeb404f95564e49eef6bc049069"},{"author":{"_account_id":1297,"name":"Joshua Harlow","email":"jxharlow@godaddy.com","username":"harlowja"},"change_message_id":"b1ed09c24b453ececf2c13238db3842a817ea9e3","unresolved":false,"context_lines":[{"line_number":310,"context_line":"  resource objects (database handles, file descriptors, sockets, ...) can **not**"},{"line_number":311,"context_line":"  be directly sent across to remote workers (instead the configuration that"},{"line_number":312,"context_line":"  defines how to fetch/create these objects must be instead)."},{"line_number":313,"context_line":"* Worker-based engines will in the future be able to run lightweight tasks"},{"line_number":314,"context_line":"  locally to avoid transport overhead for very simple tasks (currently it will"},{"line_number":315,"context_line":"  run even lightweight tasks remotely, which may be non-performant)."},{"line_number":316,"context_line":"* Fault detection, currently when a worker acknowledges a task the engine will"}],"source_content_type":"text/x-rst","patch_set":8,"id":"9ad9bd40_880a841f","line":313,"in_reply_to":"9ad9bd40_d81728a2","updated":"2014-05-02 22:16:14.000000000","message":"i think this one is ok, plural i think is fine here.","commit_id":"a0b37e5f69900aeb404f95564e49eef6bc049069"}]}