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]