Allow concurrent execution for sync_to_async calls inside library.

Author: sergey.komissarov

CHANGELOG.md

@@ -23,6 +23,10 @@ SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
 # Changelog
 
+## [1.0.0rc6] - 2023-05-10
+
+- `sync_to_async` calls inside library now runs concurrently.
+
 ## [1.0.0rc5] - 2023-05-05
 
 WARNING: Release contains backward incompatible changes!

channels_graphql_ws/graphql_ws_consumer.py

@@ -735,7 +735,7 @@ async def _on_gql_start__parse_query(
         """
 
         res = await channels.db.database_sync_to_async(
-            self._on_gql_start__parse_query_sync_cached
+            self._on_gql_start__parse_query_sync_cached, thread_sensitive=False
         )(op_name, query)
 
         doc_ast: Optional[graphql.DocumentNode] = res[0]
@@ -994,7 +994,9 @@ def enqueue_notification(payload):
         if waitlist:
             await asyncio.wait(waitlist)
 
-        _deserialize = channels.db.database_sync_to_async(Serializer.deserialize)
+        _deserialize = channels.db.database_sync_to_async(
+            Serializer.deserialize, thread_sensitive=False
+        )
 
         # For each notification (event) yielded from this function the
         # `_on_gql_start__subscribe` function will call subscription

channels_graphql_ws/subscription.py

@@ -197,7 +197,7 @@ async def broadcast_async(cls, *, group=None, payload=None):
         # Manually serialize the `payload` to allow transfer of Django
         # models inside `payload`, auto serialization does not do this.
         serialized_payload = await channels.db.database_sync_to_async(
-            Serializer.serialize
+            Serializer.serialize, thread_sensitive=False
         )(payload)
 
         # Send the message to the Channels group.

example/settings.py

@@ -83,13 +83,13 @@
     }
 ]
 INSTALLED_APPS: List[str] = [
+    "daphne",
     "django.contrib.contenttypes",
     "django.contrib.sessions",
     "django.contrib.auth",
     "django.contrib.messages",
     "django.contrib.staticfiles",
     "django.contrib.admin",
-    "daphne",
     "channels",
 ]
 ALLOWED_HOSTS = ["*"]

pyproject.toml

@@ -34,7 +34,7 @@ build-backend = "poetry.core.masonry.api"
 # Docs: https://python-poetry.org/docs/
 [tool.poetry]
 name = "django-channels-graphql-ws"
-version = "v1.0.0rc5"
+version = "v1.0.0rc6"
 description = """Django Channels based WebSocket GraphQL server with Graphene-like subscriptions"""
 authors = ["Alexander A. Prokhorov <alexander.prokhorov@datadvance.net>"]
 homepage = "https://github.com/datadvance/DjangoChannelsGraphqlWs"