From b9d6e2d1ea9fc6fb3c7694d5780ffea3a8ed36ff Mon Sep 17 00:00:00 2001 From: pengfeiqin Date: Thu, 6 Dec 2018 22:44:51 +0800 Subject: [PATCH] fix: deferred insert json.loads() typeError (#6577) --- frappe/deferred_insert.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/frappe/deferred_insert.py b/frappe/deferred_insert.py index b12b41492a..499fc5e41b 100644 --- a/frappe/deferred_insert.py +++ b/frappe/deferred_insert.py @@ -17,7 +17,7 @@ def save_to_db(): doctype = get_doctype_name(key) while frappe.cache().llen(queue_key) > 0 and record_count <= 500: records = frappe.cache().lpop(queue_key) - records = json.loads(records) + records = json.loads(records.decode('utf-8')) if isinstance(records, dict): record_count += 1 insert_record(records, doctype) @@ -41,4 +41,4 @@ def get_key_name(key): return cstr(key).split('|')[1] def get_doctype_name(key): - return cstr(key).split(queue_prefix)[1] \ No newline at end of file + return cstr(key).split(queue_prefix)[1]