update sync_to_async to database_sync_to_async (https://channels.readthedocs.io/en/stable/topics/databases.html)

aidin-leo · aidin-leo · commit 692473cd485e · 2021-01-13T13:14:31.000+03:30
diff --git a/celery_progress/websockets/consumers.py b/celery_progress/websockets/consumers.py
@@ -27,12 +27,12 @@ async def receive(self, text_data):
         task_type = text_data_json['type']
 
         if task_type == 'check_task_completion':
-            from asgiref.sync import sync_to_async
+            from channels.db import database_sync_to_async
             await self.channel_layer.group_send(
                 self.task_id,
                 {
                     'type': 'update_task_progress',
-                    'data': await sync_to_async(Progress(AsyncResult(self.task_id)).get_info, thread_sensitive=True)()
+                    'data': await database_sync_to_async(Progress(AsyncResult(self.task_id)).get_info)()
                 }
             )
 

Original file line number	Diff line number	Diff line change
`@@ -27,12 +27,12 @@ async def receive(self, text_data):`
`27`	`27`	`task_type = text_data_json['type']`
`28`	`28`
`29`	`29`	`if task_type == 'check_task_completion':`
`30`		`- from asgiref.sync import sync_to_async`
	`30`	`+ from channels.db import database_sync_to_async`
`31`	`31`	`await self.channel_layer.group_send(`
`32`	`32`	`self.task_id,`
`33`	`33`	`{`
`34`	`34`	`'type': 'update_task_progress',`
`35`		`- 'data': await sync_to_async(Progress(AsyncResult(self.task_id)).get_info, thread_sensitive=True)()`
	`35`	`+ 'data': await database_sync_to_async(Progress(AsyncResult(self.task_id)).get_info)()`
`36`	`36`	`}`
`37`	`37`	`)`
`38`	`38`