Black the example code

SmileyChris · SmileyChris · commit e904b1513b8c · 2020-06-29T10:11:48.000+12:00
diff --git a/examples/aiohttp/app.py b/examples/aiohttp/app.py
@@ -10,34 +10,35 @@
 
 async def graphql_view(request):
     payload = await request.json()
-    response = await schema.execute(payload.get('query', ''), return_promise=True)
+    response = await schema.execute(payload.get("query", ""), return_promise=True)
     data = {}
     if response.errors:
-        data['errors'] = [format_error(e) for e in response.errors]
+        data["errors"] = [format_error(e) for e in response.errors]
     if response.data:
-        data['data'] = response.data
+        data["data"] = response.data
     jsondata = json.dumps(data,)
-    return web.Response(text=jsondata, headers={'Content-Type': 'application/json'})
+    return web.Response(text=jsondata, headers={"Content-Type": "application/json"})
 
 
 async def graphiql_view(request):
-    return web.Response(text=render_graphiql(), headers={'Content-Type': 'text/html'})
+    return web.Response(text=render_graphiql(), headers={"Content-Type": "text/html"})
+
 
 subscription_server = AiohttpSubscriptionServer(schema)
 
 
 async def subscriptions(request):
-    ws = web.WebSocketResponse(protocols=('graphql-ws',))
+    ws = web.WebSocketResponse(protocols=("graphql-ws",))
     await ws.prepare(request)
 
     await subscription_server.handle(ws)
     return ws
 
 
 app = web.Application()
-app.router.add_get('/subscriptions', subscriptions)
-app.router.add_get('/graphiql', graphiql_view)
-app.router.add_get('/graphql', graphql_view)
-app.router.add_post('/graphql', graphql_view)
+app.router.add_get("/subscriptions", subscriptions)
+app.router.add_get("/graphiql", graphiql_view)
+app.router.add_get("/graphql", graphql_view)
+app.router.add_post("/graphql", graphql_view)
 
 web.run_app(app, port=8000)
diff --git a/examples/aiohttp/schema.py b/examples/aiohttp/schema.py
@@ -20,14 +20,14 @@ async def resolve_count_seconds(root, info, up_to=5):
         for i in range(up_to):
             print("YIELD SECOND", i)
             yield i
-            await asyncio.sleep(1.)
+            await asyncio.sleep(1.0)
         yield up_to
 
     async def resolve_random_int(root, info):
         i = 0
         while True:
             yield RandomType(seconds=i, random_int=random.randint(0, 500))
-            await asyncio.sleep(1.)
+            await asyncio.sleep(1.0)
             i += 1
 
 
diff --git a/examples/aiohttp/template.py b/examples/aiohttp/template.py
@@ -1,9 +1,9 @@
-
 from string import Template
 
 
 def render_graphiql():
-    return Template('''
+    return Template(
+        """
 <!DOCTYPE html>
 <html>
 <head>
@@ -116,10 +116,11 @@ def render_graphiql():
     );
   </script>
 </body>
-</html>''').substitute(
-        GRAPHIQL_VERSION='0.10.2',
-        SUBSCRIPTIONS_TRANSPORT_VERSION='0.7.0',
-        subscriptionsEndpoint='ws://localhost:8000/subscriptions',
+</html>"""
+    ).substitute(
+        GRAPHIQL_VERSION="0.10.2",
+        SUBSCRIPTIONS_TRANSPORT_VERSION="0.7.0",
+        subscriptionsEndpoint="ws://localhost:8000/subscriptions",
         # subscriptionsEndpoint='ws://localhost:5000/',
-        endpointURL='/graphql',
+        endpointURL="/graphql",
     )
diff --git a/examples/django_subscriptions/django_subscriptions/asgi.py b/examples/django_subscriptions/django_subscriptions/asgi.py
@@ -3,4 +3,4 @@
 
 os.environ.setdefault("DJANGO_SETTINGS_MODULE", "django_subscriptions.settings")
 
-channel_layer = get_channel_layer()
+channel_layer = get_channel_layer()
diff --git a/examples/django_subscriptions/django_subscriptions/schema.py b/examples/django_subscriptions/django_subscriptions/schema.py
@@ -6,18 +6,19 @@ class Query(graphene.ObjectType):
     hello = graphene.String()
 
     def resolve_hello(self, info, **kwargs):
-        return 'world'
+        return "world"
+
 
 class Subscription(graphene.ObjectType):
 
     count_seconds = graphene.Int(up_to=graphene.Int())
 
-
     def resolve_count_seconds(root, info, up_to=5):
-        return Observable.interval(1000)\
-                         .map(lambda i: "{0}".format(i))\
-                         .take_while(lambda i: int(i) <= up_to)
-
+        return (
+            Observable.interval(1000)
+            .map(lambda i: "{0}".format(i))
+            .take_while(lambda i: int(i) <= up_to)
+        )
 
 
-schema = graphene.Schema(query=Query, subscription=Subscription)
+schema = graphene.Schema(query=Query, subscription=Subscription)
diff --git a/examples/django_subscriptions/django_subscriptions/settings.py b/examples/django_subscriptions/django_subscriptions/settings.py
@@ -20,7 +20,7 @@
 # See https://docs.djangoproject.com/en/1.11/howto/deployment/checklist/
 
 # SECURITY WARNING: keep the secret key used in production secret!
-SECRET_KEY = 'fa#kz8m$l6)4(np9+-j_-z!voa090mah!s9^4jp=kj!^nwdq^c'
+SECRET_KEY = "fa#kz8m$l6)4(np9+-j_-z!voa090mah!s9^4jp=kj!^nwdq^c"
 
 # SECURITY WARNING: don't run with debug turned on in production!
 DEBUG = True
@@ -31,53 +31,53 @@
 # Application definition
 
 INSTALLED_APPS = [
-    'django.contrib.admin',
-    'django.contrib.auth',
-    'django.contrib.contenttypes',
-    'django.contrib.sessions',
-    'django.contrib.messages',
-    'django.contrib.staticfiles',
-    'channels',
+    "django.contrib.admin",
+    "django.contrib.auth",
+    "django.contrib.contenttypes",
+    "django.contrib.sessions",
+    "django.contrib.messages",
+    "django.contrib.staticfiles",
+    "channels",
 ]
 
 MIDDLEWARE = [
-    'django.middleware.security.SecurityMiddleware',
-    'django.contrib.sessions.middleware.SessionMiddleware',
-    'django.middleware.common.CommonMiddleware',
-    'django.middleware.csrf.CsrfViewMiddleware',
-    'django.contrib.auth.middleware.AuthenticationMiddleware',
-    'django.contrib.messages.middleware.MessageMiddleware',
-    'django.middleware.clickjacking.XFrameOptionsMiddleware',
+    "django.middleware.security.SecurityMiddleware",
+    "django.contrib.sessions.middleware.SessionMiddleware",
+    "django.middleware.common.CommonMiddleware",
+    "django.middleware.csrf.CsrfViewMiddleware",
+    "django.contrib.auth.middleware.AuthenticationMiddleware",
+    "django.contrib.messages.middleware.MessageMiddleware",
+    "django.middleware.clickjacking.XFrameOptionsMiddleware",
 ]
 
-ROOT_URLCONF = 'django_subscriptions.urls'
+ROOT_URLCONF = "django_subscriptions.urls"
 
 TEMPLATES = [
     {
-        'BACKEND': 'django.template.backends.django.DjangoTemplates',
-        'DIRS': [],
-        'APP_DIRS': True,
-        'OPTIONS': {
-            'context_processors': [
-                'django.template.context_processors.debug',
-                'django.template.context_processors.request',
-                'django.contrib.auth.context_processors.auth',
-                'django.contrib.messages.context_processors.messages',
+        "BACKEND": "django.template.backends.django.DjangoTemplates",
+        "DIRS": [],
+        "APP_DIRS": True,
+        "OPTIONS": {
+            "context_processors": [
+                "django.template.context_processors.debug",
+                "django.template.context_processors.request",
+                "django.contrib.auth.context_processors.auth",
+                "django.contrib.messages.context_processors.messages",
             ],
         },
     },
 ]
 
-WSGI_APPLICATION = 'django_subscriptions.wsgi.application'
+WSGI_APPLICATION = "django_subscriptions.wsgi.application"
 
 
 # Database
 # https://docs.djangoproject.com/en/1.11/ref/settings/#databases
 
 DATABASES = {
-    'default': {
-        'ENGINE': 'django.db.backends.sqlite3',
-        'NAME': os.path.join(BASE_DIR, 'db.sqlite3'),
+    "default": {
+        "ENGINE": "django.db.backends.sqlite3",
+        "NAME": os.path.join(BASE_DIR, "db.sqlite3"),
     }
 }
 
@@ -87,26 +87,20 @@
 
 AUTH_PASSWORD_VALIDATORS = [
     {
-        'NAME': 'django.contrib.auth.password_validation.UserAttributeSimilarityValidator',
-    },
-    {
-        'NAME': 'django.contrib.auth.password_validation.MinimumLengthValidator',
-    },
-    {
-        'NAME': 'django.contrib.auth.password_validation.CommonPasswordValidator',
-    },
-    {
-        'NAME': 'django.contrib.auth.password_validation.NumericPasswordValidator',
+        "NAME": "django.contrib.auth.password_validation.UserAttributeSimilarityValidator",
     },
+    {"NAME": "django.contrib.auth.password_validation.MinimumLengthValidator"},
+    {"NAME": "django.contrib.auth.password_validation.CommonPasswordValidator"},
+    {"NAME": "django.contrib.auth.password_validation.NumericPasswordValidator"},
 ]
 
 
 # Internationalization
 # https://docs.djangoproject.com/en/1.11/topics/i18n/
 
-LANGUAGE_CODE = 'en-us'
+LANGUAGE_CODE = "en-us"
 
-TIME_ZONE = 'UTC'
+TIME_ZONE = "UTC"
 
 USE_I18N = True
 
@@ -118,20 +112,17 @@
 # Static files (CSS, JavaScript, Images)
 # https://docs.djangoproject.com/en/1.11/howto/static-files/
 
-STATIC_URL = '/static/'
-CHANNELS_WS_PROTOCOLS = ["graphql-ws", ]
+STATIC_URL = "/static/"
+CHANNELS_WS_PROTOCOLS = [
+    "graphql-ws",
+]
 CHANNEL_LAYERS = {
     "default": {
         "BACKEND": "asgi_redis.RedisChannelLayer",
-        "CONFIG": {
-            "hosts": [("localhost", 6379)],
-        },
+        "CONFIG": {"hosts": [("localhost", 6379)]},
         "ROUTING": "django_subscriptions.urls.channel_routing",
     },
-
 }
 
 
-GRAPHENE = {
-    'SCHEMA': 'django_subscriptions.schema.schema'
-}
+GRAPHENE = {"SCHEMA": "django_subscriptions.schema.schema"}
diff --git a/examples/django_subscriptions/django_subscriptions/template.py b/examples/django_subscriptions/django_subscriptions/template.py
@@ -1,9 +1,9 @@
-
 from string import Template
 
 
 def render_graphiql():
-    return Template('''
+    return Template(
+        """
 <!DOCTYPE html>
 <html>
 <head>
@@ -116,10 +116,11 @@ def render_graphiql():
     );
   </script>
 </body>
-</html>''').substitute(
-        GRAPHIQL_VERSION='0.11.10',
-        SUBSCRIPTIONS_TRANSPORT_VERSION='0.7.0',
-        subscriptionsEndpoint='ws://localhost:8000/subscriptions',
+</html>"""
+    ).substitute(
+        GRAPHIQL_VERSION="0.11.10",
+        SUBSCRIPTIONS_TRANSPORT_VERSION="0.7.0",
+        subscriptionsEndpoint="ws://localhost:8000/subscriptions",
         # subscriptionsEndpoint='ws://localhost:5000/',
-        endpointURL='/graphql',
+        endpointURL="/graphql",
     )
diff --git a/examples/django_subscriptions/django_subscriptions/urls.py b/examples/django_subscriptions/django_subscriptions/urls.py
@@ -21,20 +21,21 @@
 from graphene_django.views import GraphQLView
 from django.views.decorators.csrf import csrf_exempt
 
+from channels.routing import route_class
+from graphql_ws.django_channels import GraphQLSubscriptionConsumer
+
 
 def graphiql(request):
     response = HttpResponse(content=render_graphiql())
     return response
 
+
 urlpatterns = [
-    url(r'^admin/', admin.site.urls),
-    url(r'^graphiql/', graphiql),
-    url(r'^graphql', csrf_exempt(GraphQLView.as_view(graphiql=True)))
+    url(r"^admin/", admin.site.urls),
+    url(r"^graphiql/", graphiql),
+    url(r"^graphql", csrf_exempt(GraphQLView.as_view(graphiql=True))),
 ]
 
-from channels.routing import route_class
-from graphql_ws.django_channels import GraphQLSubscriptionConsumer
-
 channel_routing = [
     route_class(GraphQLSubscriptionConsumer, path=r"^/subscriptions"),
-]
+]
diff --git a/examples/flask_gevent/app.py b/examples/flask_gevent/app.py
@@ -1,5 +1,3 @@
-import json
-
 from flask import Flask, make_response
 from flask_graphql import GraphQLView
 from flask_sockets import Sockets
@@ -14,19 +12,20 @@
 sockets = Sockets(app)
 
 
-@app.route('/graphiql')
+@app.route("/graphiql")
 def graphql_view():
     return make_response(render_graphiql())
 
 
 app.add_url_rule(
-    '/graphql', view_func=GraphQLView.as_view('graphql', schema=schema, graphiql=False))
+    "/graphql", view_func=GraphQLView.as_view("graphql", schema=schema, graphiql=False)
+)
 
 subscription_server = GeventSubscriptionServer(schema)
-app.app_protocol = lambda environ_path_info: 'graphql-ws'
+app.app_protocol = lambda environ_path_info: "graphql-ws"
 
 
-@sockets.route('/subscriptions')
+@sockets.route("/subscriptions")
 def echo_socket(ws):
     subscription_server.handle(ws)
     return []
@@ -35,5 +34,6 @@ def echo_socket(ws):
 if __name__ == "__main__":
     from gevent import pywsgi
     from geventwebsocket.handler import WebSocketHandler
-    server = pywsgi.WSGIServer(('', 5000), app, handler_class=WebSocketHandler)
+
+    server = pywsgi.WSGIServer(("", 5000), app, handler_class=WebSocketHandler)
     server.serve_forever()
diff --git a/examples/flask_gevent/schema.py b/examples/flask_gevent/schema.py
@@ -19,12 +19,16 @@ class Subscription(graphene.ObjectType):
     random_int = graphene.Field(RandomType)
 
     def resolve_count_seconds(root, info, up_to=5):
-        return Observable.interval(1000)\
-                         .map(lambda i: "{0}".format(i))\
-                         .take_while(lambda i: int(i) <= up_to)
+        return (
+            Observable.interval(1000)
+            .map(lambda i: "{0}".format(i))
+            .take_while(lambda i: int(i) <= up_to)
+        )
 
     def resolve_random_int(root, info):
-        return Observable.interval(1000).map(lambda i: RandomType(seconds=i, random_int=random.randint(0, 500)))
+        return Observable.interval(1000).map(
+            lambda i: RandomType(seconds=i, random_int=random.randint(0, 500))
+        )
 
 
 schema = graphene.Schema(query=Query, subscription=Subscription)
diff --git a/examples/flask_gevent/template.py b/examples/flask_gevent/template.py
diff --git a/examples/websockets_lib/app.py b/examples/websockets_lib/app.py
diff --git a/examples/websockets_lib/schema.py b/examples/websockets_lib/schema.py
diff --git a/examples/websockets_lib/template.py b/examples/websockets_lib/template.py

Original file line number	Diff line number	Diff line change
`@@ -3,4 +3,4 @@`
`3`	`3`
`4`	`4`	`os.environ.setdefault("DJANGO_SETTINGS_MODULE", "django_subscriptions.settings")`
`5`	`5`
`6`		`-channel_layer = get_channel_layer()`
	`6`	`+channel_layer = get_channel_layer()`