feat: use json

djcelery/admin.py

@@ -1,6 +1,6 @@
 from __future__ import absolute_import, unicode_literals
 
-from anyjson import loads
+from json import loads
 
 from django import forms
 from django.conf import settings

djcelery/schedulers.py

@@ -4,7 +4,7 @@
 
 from multiprocessing.util import Finalize
 
-from anyjson import loads, dumps
+from json import loads, dumps
 from celery import current_app
 from celery import schedules
 from celery.beat import Scheduler, ScheduleEntry

djcelery/tests/test_views.py

@@ -10,7 +10,7 @@
 from django.test.testcases import TestCase as DjangoTestCase
 from django.template import TemplateDoesNotExist
 
-from anyjson import deserialize
+from json import loads
 
 from celery import current_app
 from celery import states
@@ -72,7 +72,7 @@ class ViewTestCase(DjangoTestCase):
     def assertJSONEqual(self, json, py):
         json = isinstance(json, HttpResponse) and json.content or json
         try:
-            self.assertEqual(deserialize(json.decode('utf-8')), py)
+            self.assertEqual(loads(json.decode('utf-8')), py)
         except TypeError as exc:
             raise TypeError('{0}: {1}'.format(exc, json))
 
@@ -122,7 +122,7 @@ class test_registered_tasks(ViewTestCase):
 
     def test_list_registered_tasks(self):
         json = self.client.get(registered_tasks())
-        tasks = deserialize(json.content.decode('utf-8'))
+        tasks = loads(json.content.decode('utf-8'))
         self.assertIn('celery.backend_cleanup', tasks['regular'])
 
 
@@ -140,7 +140,7 @@ def add_webhook(request):
         response = add_webhook(request)
         self.assertDictContainsSubset(
             {'status': 'success', 'retval': 20},
-            deserialize(response.content.decode('utf-8')))
+            loads(response.content.decode('utf-8')))
 
     def test_failed_request(self):
 
@@ -155,7 +155,7 @@ def error_webhook(request):
         self.assertDictContainsSubset(
             {'status': 'failure',
              'reason': '<MyError: (20,)>'},
-            deserialize(response.content.decode('utf-8')))
+            loads(response.content.decode('utf-8')))
 
 
 class test_task_status(ViewTestCase):

djcelery/views.py

@@ -4,7 +4,7 @@
 
 from django.http import HttpResponse, Http404
 
-from anyjson import serialize
+from json import dumps
 
 from celery import states
 from celery.five import keys, items
@@ -18,7 +18,7 @@
 
 
 def JsonResponse(response):
-    return HttpResponse(serialize(response), content_type='application/json')
+    return HttpResponse(dumps(response), content_type='application/json')
 
 
 def task_view(task):