)]}'
{"gnocchi/cli.py":[{"author":{"_account_id":12807,"name":"Steve Lewis (stevelle)","email":"stevelle@gmail.com","username":"stevelle"},"change_message_id":"2f0edb47e7032f89166bdf5586f731a9894773b6","unresolved":false,"context_lines":[{"line_number":110,"context_line":"    def terminate(self):"},{"line_number":111,"context_line":"        self._shutdown.set()"},{"line_number":112,"context_line":"        self.close_queues()"},{"line_number":113,"context_line":"        LOG.info(\"Waiting ongoing metric processing to finish\")"},{"line_number":114,"context_line":"        self._shutdown_done.wait()"},{"line_number":115,"context_line":""},{"line_number":116,"context_line":"    @staticmethod"}],"source_content_type":"text/x-python","patch_set":2,"id":"1a122d0e_975528fc","line":113,"range":{"start_line":113,"start_character":26,"end_line":113,"end_character":33},"updated":"2016-05-02 23:02:11.000000000","message":"\"Waiting for\" sounds better","commit_id":"dea4045955eb650af991e39812419e6467938f2d"},{"author":{"_account_id":6537,"name":"gordon chung","email":"gord@live.ca","username":"chungg"},"change_message_id":"d4c23124f9f5477497fdf89dff1e8984d966e808","unresolved":false,"context_lines":[{"line_number":158,"context_line":""},{"line_number":159,"context_line":"    def close_queues(self):"},{"line_number":160,"context_line":"        for queue in self.queues:"},{"line_number":161,"context_line":"            queue.close()"},{"line_number":162,"context_line":""},{"line_number":163,"context_line":""},{"line_number":164,"context_line":"class MetricJanitor(MetricProcessBase):"}],"source_content_type":"text/x-python","patch_set":14,"id":"1aa78d24_2810644d","line":161,"updated":"2016-07-13 15:45:14.000000000","message":"i think this will close twice? both producer and consumer below are closing.","commit_id":"a65f0d9560cc94e6100747a2f12dc1bd7d4f19a0"},{"author":{"_account_id":2813,"name":"Mehdi Abaakouk","email":"sileht@sileht.net","username":"sileht"},"change_message_id":"8290beed89aba5eadd60a6b040ca6ed65b72cd50","unresolved":false,"context_lines":[{"line_number":158,"context_line":""},{"line_number":159,"context_line":"    def close_queues(self):"},{"line_number":160,"context_line":"        for queue in self.queues:"},{"line_number":161,"context_line":"            queue.close()"},{"line_number":162,"context_line":""},{"line_number":163,"context_line":""},{"line_number":164,"context_line":"class MetricJanitor(MetricProcessBase):"}],"source_content_type":"text/x-python","patch_set":14,"id":"1aa78d24_374d5d3e","line":161,"in_reply_to":"1aa78d24_2810644d","updated":"2016-07-13 17:08:28.000000000","message":"Yes but the queue objects are forked and need to be closed on both side.","commit_id":"a65f0d9560cc94e6100747a2f12dc1bd7d4f19a0"},{"author":{"_account_id":6537,"name":"gordon chung","email":"gord@live.ca","username":"chungg"},"change_message_id":"d4c23124f9f5477497fdf89dff1e8984d966e808","unresolved":false,"context_lines":[{"line_number":177,"context_line":""},{"line_number":178,"context_line":""},{"line_number":179,"context_line":"class MetricProcessor(MetricProcessBase):"},{"line_number":180,"context_line":"    name \u003d \"processing\""},{"line_number":181,"context_line":""},{"line_number":182,"context_line":"    def __init__(self, worker_id, conf, queue):"},{"line_number":183,"context_line":"        super(MetricProcessor, self).__init__("}],"source_content_type":"text/x-python","patch_set":14,"id":"1aa78d24_c84e006e","line":180,"updated":"2016-07-13 15:45:14.000000000","message":"is this some secret param required to be passed in?","commit_id":"a65f0d9560cc94e6100747a2f12dc1bd7d4f19a0"},{"author":{"_account_id":2813,"name":"Mehdi Abaakouk","email":"sileht@sileht.net","username":"sileht"},"change_message_id":"8290beed89aba5eadd60a6b040ca6ed65b72cd50","unresolved":false,"context_lines":[{"line_number":177,"context_line":""},{"line_number":178,"context_line":""},{"line_number":179,"context_line":"class MetricProcessor(MetricProcessBase):"},{"line_number":180,"context_line":"    name \u003d \"processing\""},{"line_number":181,"context_line":""},{"line_number":182,"context_line":"    def __init__(self, worker_id, conf, queue):"},{"line_number":183,"context_line":"        super(MetricProcessor, self).__init__("}],"source_content_type":"text/x-python","patch_set":14,"id":"1aa78d24_d7a5f902","line":180,"in_reply_to":"1aa78d24_c84e006e","updated":"2016-07-13 17:08:28.000000000","message":"It\u0027s optional, but yes that part of the API of cotyledon to set the unix/window process name. So, with \u0027ps\u0027 you will see if that the janitor or the reporter that consume all the cpus","commit_id":"a65f0d9560cc94e6100747a2f12dc1bd7d4f19a0"}]}