)]}'
{"mistral/api/controllers/v2/execution.py":[{"author":{"_account_id":8731,"name":"Renat Akhmerov","email":"renat.akhmerov@gmail.com","username":"rakhmerov"},"change_message_id":"a1cc47c2bbb8dcca8cb9e23ae3d292c96445526d","unresolved":false,"context_lines":[{"line_number":224,"context_line":"        engine \u003d rpc.get_engine_client()"},{"line_number":225,"context_line":"        exec_dict \u003d wf_ex.to_dict()"},{"line_number":226,"context_line":""},{"line_number":227,"context_line":"        if not (exec_dict.get(\u0027workflow_id\u0027)"},{"line_number":228,"context_line":"                or exec_dict.get(\u0027workflow_name\u0027)):"},{"line_number":229,"context_line":"            raise exc.WorkflowException("},{"line_number":230,"context_line":"                \"Workflow ID or workflow name must be provided. Workflow ID is\""}],"source_content_type":"text/x-python","patch_set":7,"id":"5a5ae5dd_6f4f3334","line":227,"range":{"start_line":227,"start_character":16,"end_line":227,"end_character":25},"updated":"2016-02-08 17:12:48.000000000","message":"This code is going to be pretty typical. I wonder if we can refactor it with a common method.","commit_id":"54a8e304069cf5be46b57e1119a20fbb030e8e6e"}],"mistral/engine/task_handler.py":[{"author":{"_account_id":18238,"name":"Hardik Parekh","email":"hardik.parekh047@gmail.com","username":"hparekh"},"change_message_id":"e5efd2d3c1271f82abb77de852060f10bd0008f1","unresolved":false,"context_lines":[{"line_number":134,"context_line":""},{"line_number":135,"context_line":"    LOG.debug("},{"line_number":136,"context_line":"        \u0027Starting workflow task [task_name\u003d%s, task_spec\u003d%s, init_state\u003d%s]\u0027 %"},{"line_number":137,"context_line":"        (wf_ex.name, task_spec, task_ex.state)"},{"line_number":138,"context_line":"    )"},{"line_number":139,"context_line":""},{"line_number":140,"context_line":"    # TODO(rakhmerov): \u0027concurrency\u0027 policy should keep a number of running"}],"source_content_type":"text/x-python","patch_set":5,"id":"5a5ae5dd_8de829e4","line":137,"range":{"start_line":137,"start_character":9,"end_line":137,"end_character":19},"updated":"2016-02-04 00:39:23.000000000","message":"task_ex.name ?","commit_id":"66ecb0a96ddf596b6764071a10f6764b582d2cc1"},{"author":{"_account_id":6732,"name":"Lingxian Kong","email":"anlin.kong@gmail.com","username":"kong"},"change_message_id":"f5f6360a3f6a089d45af1e4e8aa673b14c7ba3a8","unresolved":false,"context_lines":[{"line_number":134,"context_line":""},{"line_number":135,"context_line":"    LOG.debug("},{"line_number":136,"context_line":"        \u0027Starting workflow task [task_name\u003d%s, task_spec\u003d%s, init_state\u003d%s]\u0027 %"},{"line_number":137,"context_line":"        (wf_ex.name, task_spec, task_ex.state)"},{"line_number":138,"context_line":"    )"},{"line_number":139,"context_line":""},{"line_number":140,"context_line":"    # TODO(rakhmerov): \u0027concurrency\u0027 policy should keep a number of running"}],"source_content_type":"text/x-python","patch_set":5,"id":"5a5ae5dd_c7691a27","line":137,"range":{"start_line":137,"start_character":9,"end_line":137,"end_character":19},"in_reply_to":"5a5ae5dd_8de829e4","updated":"2016-02-04 03:49:09.000000000","message":"hmm...let\u0027s keep what it was.","commit_id":"66ecb0a96ddf596b6764071a10f6764b582d2cc1"}]}