)]}'
{"taskflow/engines/worker_based/dispatcher.py":[{"author":{"_account_id":9608,"name":"Pranesh Pandurangan","email":"praneshpg@gmail.com","username":"pran1990"},"change_message_id":"d6c160d68fda3b380a96f6c794bc57beb2fbfd76","unresolved":false,"context_lines":[{"line_number":87,"context_line":"                             \" in an invalid format: %s\","},{"line_number":88,"context_line":"                             message.delivery_tag, message_type, e)"},{"line_number":89,"context_line":"                    return"},{"line_number":90,"context_line":"            message.ack_log_error(logger\u003dLOG,"},{"line_number":91,"context_line":"                                  errors\u003d(kombu_exc.MessageStateError,))"},{"line_number":92,"context_line":"            if message.acknowledged:"},{"line_number":93,"context_line":"                LOG.debug(\"AMQP message %r acknowledged.\","}],"source_content_type":"text/x-python","patch_set":11,"id":"baada198_47247fb1","line":90,"updated":"2014-08-02 23:22:18.000000000","message":"Unsure why this is here.  Why throw an error everytime a handler is present","commit_id":"9bce85dc66c5ef1be6ba0e504baae104903ed377"},{"author":{"_account_id":1297,"name":"Joshua Harlow","email":"jxharlow@godaddy.com","username":"harlowja"},"change_message_id":"6565c1b456a94f4e15342a229c4291f01f90894a","unresolved":false,"context_lines":[{"line_number":87,"context_line":"                             \" in an invalid format: %s\","},{"line_number":88,"context_line":"                             message.delivery_tag, message_type, e)"},{"line_number":89,"context_line":"                    return"},{"line_number":90,"context_line":"            message.ack_log_error(logger\u003dLOG,"},{"line_number":91,"context_line":"                                  errors\u003d(kombu_exc.MessageStateError,))"},{"line_number":92,"context_line":"            if message.acknowledged:"},{"line_number":93,"context_line":"                LOG.debug(\"AMQP message %r acknowledged.\","}],"source_content_type":"text/x-python","patch_set":11,"id":"baada198_87769790","line":90,"in_reply_to":"baada198_47247fb1","updated":"2014-08-02 23:46:45.000000000","message":"This basically will ack (acknowledge) the message (and use the given logger if the ack fails for the given errors). So this is the ack part of the processing (which acks to the message queue that the message has been recieved). Hopefully makes sense.","commit_id":"9bce85dc66c5ef1be6ba0e504baae104903ed377"},{"author":{"_account_id":1297,"name":"Joshua Harlow","email":"jxharlow@godaddy.com","username":"harlowja"},"change_message_id":"63519184555e33f1bbf05bb1fa1715bd70ccdfce","unresolved":false,"context_lines":[{"line_number":87,"context_line":"                             \" in an invalid format: %s\","},{"line_number":88,"context_line":"                             message.delivery_tag, message_type, e)"},{"line_number":89,"context_line":"                    return"},{"line_number":90,"context_line":"            message.ack_log_error(logger\u003dLOG,"},{"line_number":91,"context_line":"                                  errors\u003d(kombu_exc.MessageStateError,))"},{"line_number":92,"context_line":"            if message.acknowledged:"},{"line_number":93,"context_line":"                LOG.debug(\"AMQP message %r acknowledged.\","}],"source_content_type":"text/x-python","patch_set":11,"id":"baada198_078a8764","line":90,"in_reply_to":"baada198_87769790","updated":"2014-08-02 23:49:13.000000000","message":"Uses the following:\n\nhttps://github.com/celery/kombu/blob/master/kombu/message.py#L91","commit_id":"9bce85dc66c5ef1be6ba0e504baae104903ed377"}]}