)]}'
{"marconi/queues/storage/redis/catalogue.py":[{"author":{"_account_id":10634,"name":"Peng Fei Wang","email":"wpf710@gmail.com","username":"wpf"},"change_message_id":"9b5606eec67cceb94ff126d765571a3d2b7a41e2","unresolved":false,"context_lines":[{"line_number":60,"context_line":"    def get(self, project, queue):"},{"line_number":61,"context_line":""},{"line_number":62,"context_line":"        if not self.exists(project, queue):"},{"line_number":63,"context_line":"            raise errors.QueueNotMapped(project, queue)"},{"line_number":64,"context_line":""},{"line_number":65,"context_line":"        ctlg_name \u003d utils.scope_queue_catalogue(queue, project,"},{"line_number":66,"context_line":"                                                QUEUE_CATALOGUE_SUFFIX)"}],"source_content_type":"text/x-python","patch_set":1,"id":"baada198_2fdc3d12","line":63,"updated":"2014-07-02 03:29:29.000000000","message":"QueueNotMapped was defined with (queue, project) , so you need to re-order the parameters","commit_id":"36c8d4ff047f1c4388bab48abccff7c2a60ddbad"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":23,"context_line":"    ---------------------"},{"line_number":24,"context_line":"    Id                                     Value"},{"line_number":25,"context_line":"    --------------------------------------------------"},{"line_number":26,"context_line":"    \u0027project_queue_ctlg\u0027   -\u003e             \u0027pool\u0027"},{"line_number":27,"context_line":"\"\"\""},{"line_number":28,"context_line":"from marconi.queues.storage import base"},{"line_number":29,"context_line":"from marconi.queues.storage import errors"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_77b0a38b","line":26,"updated":"2014-07-10 19:54:17.000000000","message":"project_queue_ctlg -\u003e project_queue","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":126,"context_line":"                                                     pool)"},{"line_number":127,"context_line":""},{"line_number":128,"context_line":"        ctlg_entries \u003d self._client.zrange(ctlg_shard_name, 0, -1)"},{"line_number":129,"context_line":"        pipe.delete(ctlg_shard_name)"},{"line_number":130,"context_line":""},{"line_number":131,"context_line":"        for ctlg_entry in ctlg_entries:"},{"line_number":132,"context_line":"            pipe.delete(ctlg_entry)"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_f763d317","line":129,"updated":"2014-07-10 19:54:17.000000000","message":"shard -\u003e pool\n\nIn the previous 6 lines.","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"}],"marconi/queues/storage/redis/pools.py":[{"author":{"_account_id":10777,"name":"Nataliia Uvarova","email":"grafinya.uvarova@gmail.com","username":"AAzza"},"change_message_id":"3d09b0a452df0c5dbb2835e629521f900e2d7b52","unresolved":false,"context_lines":[{"line_number":56,"context_line":"             detailed\u003dFalse):"},{"line_number":57,"context_line":"        client \u003d self._client"},{"line_number":58,"context_line":""},{"line_number":59,"context_line":"        # A limit of -1 is used when selecting a shard to"},{"line_number":60,"context_line":"        # register into the catalogue."},{"line_number":61,"context_line":"        start \u003d client.zrank(POOLS_SET_NAME, marker) or 0"},{"line_number":62,"context_line":"        end \u003d -1 if not limit else start+limit"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_5a721fae","line":59,"updated":"2014-07-16 16:54:36.000000000","message":"does this comment should be above the line 62?","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":56,"context_line":"             detailed\u003dFalse):"},{"line_number":57,"context_line":"        client \u003d self._client"},{"line_number":58,"context_line":""},{"line_number":59,"context_line":"        # A limit of -1 is used when selecting a shard to"},{"line_number":60,"context_line":"        # register into the catalogue."},{"line_number":61,"context_line":"        start \u003d client.zrank(POOLS_SET_NAME, marker) or 0"},{"line_number":62,"context_line":"        end \u003d -1 if not limit else start+limit"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_5771dfde","line":59,"updated":"2014-07-10 19:54:17.000000000","message":"shard -\u003e pool","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":60,"context_line":"        # register into the catalogue."},{"line_number":61,"context_line":"        start \u003d client.zrank(POOLS_SET_NAME, marker) or 0"},{"line_number":62,"context_line":"        end \u003d -1 if not limit else start+limit"},{"line_number":63,"context_line":"        shard_cursor \u003d (q for q in client.zrange(POOLS_SET_NAME, start, end))"},{"line_number":64,"context_line":""},{"line_number":65,"context_line":"        def _it():"},{"line_number":66,"context_line":"            for pool_name in shard_cursor:"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_7777c3d4","line":63,"updated":"2014-07-10 19:54:17.000000000","message":"shard -\u003e pool","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":63,"context_line":"        shard_cursor \u003d (q for q in client.zrange(POOLS_SET_NAME, start, end))"},{"line_number":64,"context_line":""},{"line_number":65,"context_line":"        def _it():"},{"line_number":66,"context_line":"            for pool_name in shard_cursor:"},{"line_number":67,"context_line":"                pool_info \u003d client.hgetall(pool_name)"},{"line_number":68,"context_line":"                pool_info[\u0027n\u0027] \u003d pool_name"},{"line_number":69,"context_line":"                if not detailed:"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_b7815b91","line":66,"updated":"2014-07-10 19:54:17.000000000","message":"shard -\u003e pool","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":75,"context_line":"    @utils.raises_conn_error"},{"line_number":76,"context_line":"    @utils.reset_pipeline"},{"line_number":77,"context_line":"    def create(self, name, weight, uri, options\u003dNone):"},{"line_number":78,"context_line":"        # (Doubt):The WSGI layer does not expect any"},{"line_number":79,"context_line":"        # response from the storage backend. Errors"},{"line_number":80,"context_line":"        # are not being trapped as well."},{"line_number":81,"context_line":"        pipe \u003d self._pipeline"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_f295a1e4","line":78,"updated":"2014-07-10 19:54:17.000000000","message":"NOTE(\u003cname\u003e): Doubt - ...","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":109,"context_line":"    @utils.raises_conn_error"},{"line_number":110,"context_line":"    @utils.reset_pipeline"},{"line_number":111,"context_line":"    def delete(self, name):"},{"line_number":112,"context_line":"        # Note(prashanthr_): Does not raise any errors when the shard does not"},{"line_number":113,"context_line":"        # exist."},{"line_number":114,"context_line":"        if not self.exists(name):"},{"line_number":115,"context_line":"            raise errors.PoolDoesNotExist(name)"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_d77c0fb8","line":112,"updated":"2014-07-10 19:54:17.000000000","message":"NOTE(prashanthr_): ...\n\nshard -\u003e pool","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":117,"context_line":"        pipe \u003d self._pipeline"},{"line_number":118,"context_line":"        pipe.delete(name)"},{"line_number":119,"context_line":"        pipe.zrem(POOLS_SET_NAME, name)"},{"line_number":120,"context_line":"        # Drop all the corresponding catalogue entries for the shard."},{"line_number":121,"context_line":"        # Note(prashanthr_ -\u003e cppcabrera): Is this required?"},{"line_number":122,"context_line":"        self.driver.catalogue_controller._drop_all_frompool(name)"},{"line_number":123,"context_line":"        pipe.execute()"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_37454b70","line":120,"updated":"2014-07-10 19:54:17.000000000","message":"shard -\u003e pool","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":118,"context_line":"        pipe.delete(name)"},{"line_number":119,"context_line":"        pipe.zrem(POOLS_SET_NAME, name)"},{"line_number":120,"context_line":"        # Drop all the corresponding catalogue entries for the shard."},{"line_number":121,"context_line":"        # Note(prashanthr_ -\u003e cppcabrera): Is this required?"},{"line_number":122,"context_line":"        self.driver.catalogue_controller._drop_all_frompool(name)"},{"line_number":123,"context_line":"        pipe.execute()"},{"line_number":124,"context_line":""}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_d2a5fd47","line":121,"updated":"2014-07-10 19:54:17.000000000","message":"If a pool is deleted, all catalogue entries associated with that pool should be removed, since they are effectively invalidated.","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":143,"context_line":"    @utils.raises_conn_error"},{"line_number":144,"context_line":"    @utils.reset_pipeline"},{"line_number":145,"context_line":"    def drop_all(self):"},{"line_number":146,"context_line":"        # Note(prashanthr_): Not being used from the transport"},{"line_number":147,"context_line":"        # driver."},{"line_number":148,"context_line":"        pipe \u003d self._pipeline"},{"line_number":149,"context_line":"        pools \u003d self._client.zrange(POOLS_SET_NAME, 0, -1)"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_326e3902","line":146,"updated":"2014-07-10 19:54:17.000000000","message":"NOTE(...): ...","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"},{"author":{"_account_id":6944,"name":"Allele Dev","email":"cpp.cabrera@gmail.com","username":"cpp-cabrera"},"change_message_id":"4509cdb02b59a3ca0ed67c52a057c7bc5652b435","unresolved":false,"context_lines":[{"line_number":148,"context_line":"        pipe \u003d self._pipeline"},{"line_number":149,"context_line":"        pools \u003d self._client.zrange(POOLS_SET_NAME, 0, -1)"},{"line_number":150,"context_line":""},{"line_number":151,"context_line":"        # Remove all shards from the set of shards."},{"line_number":152,"context_line":"        pipe.zremrangebyscore(POOLS_SET_NAME, 0, -1)"},{"line_number":153,"context_line":"        for pool in pools:"},{"line_number":154,"context_line":"            pipe.delete(pool)"}],"source_content_type":"text/x-python","patch_set":2,"id":"baada198_5748ff86","line":151,"updated":"2014-07-10 19:54:17.000000000","message":"shard -\u003e pool","commit_id":"70d05e1bbcae76e2b43bc668ea2f1322833ffc0b"}]}