File tree 6 files changed +14
-10
lines changed 6 files changed +14
-10
lines changed Original file line number Diff line number Diff line change @@ -50,9 +50,12 @@ clean-test: ## remove test and coverage artifacts
50
50
lint : # # check style with flake8
51
51
flake8 graphql_ws tests
52
52
53
+ format :
54
+ black ./graphql_ws ./tests
55
+
53
56
test : # # run tests quickly with the default Python
54
57
py.test
55
-
58
+
56
59
57
60
test-all : # # run tests on every Python version with tox
58
61
tox
Original file line number Diff line number Diff line change @@ -41,7 +41,7 @@ def remove_operation(self, op_id):
41
41
42
42
def unsubscribe (self , op_id ):
43
43
async_iterator = self .remove_operation (op_id )
44
- if hasattr (async_iterator , ' dispose' ):
44
+ if hasattr (async_iterator , " dispose" ):
45
45
async_iterator .dispose ()
46
46
return async_iterator
47
47
Original file line number Diff line number Diff line change 7
7
8
8
9
9
class GraphQLSubscriptionConsumer (AsyncJsonWebsocketConsumer ):
10
-
11
10
async def connect (self ):
12
11
self .connection_context = None
13
12
if WS_PROTOCOL in self .scope ["subprotocols" ]:
Original file line number Diff line number Diff line change 15
15
channels_version_tuple = get_version_tuple (channels_version )
16
16
17
17
18
- if channels_version_tuple > (3 , 0 , 0 ):
19
- websocket_urlpatterns = [path ("subscriptions" , GraphQLSubscriptionConsumer .as_asgi ())]
18
+ if channels_version_tuple > (3 , 0 , 0 ):
19
+ websocket_urlpatterns = [
20
+ path ("subscriptions" , GraphQLSubscriptionConsumer .as_asgi ())
21
+ ]
20
22
else :
21
23
websocket_urlpatterns = [path ("subscriptions" , GraphQLSubscriptionConsumer )]
22
24
Original file line number Diff line number Diff line change @@ -91,7 +91,7 @@ def test_observer_data():
91
91
send_error = send_error ,
92
92
send_message = send_message ,
93
93
)
94
- observer .on_next (' data' )
94
+ observer .on_next (" data" )
95
95
assert send_result .called
96
96
assert not send_error .called
97
97
@@ -107,6 +107,6 @@ def test_observer_exception():
107
107
send_error = send_error ,
108
108
send_message = send_message ,
109
109
)
110
- observer .on_next (TypeError (' some bad message' ))
110
+ observer .on_next (TypeError (" some bad message" ))
111
111
assert send_error .called
112
112
assert not send_result .called
Original file line number Diff line number Diff line change @@ -83,18 +83,18 @@ async def test_resolver_with_promise(server):
83
83
connection_context = None , op_id = 1 , execution_result = result
84
84
)
85
85
assert server .send_message .called
86
- assert result .data == {' test' : [1 , 2 ]}
86
+ assert result .data == {" test" : [1 , 2 ]}
87
87
88
88
89
89
async def test_resolver_with_nested_promise (server ):
90
90
server .send_message = AsyncMock ()
91
91
result = mock .Mock ()
92
92
inner = promise .Promise (lambda resolve , reject : resolve (2 ))
93
- outer = promise .Promise (lambda resolve , reject : resolve ({'in' : inner }))
93
+ outer = promise .Promise (lambda resolve , reject : resolve ({"in" : inner }))
94
94
result .data = {"test" : [1 , outer ]}
95
95
result .errors = None
96
96
await server .send_execution_result (
97
97
connection_context = None , op_id = 1 , execution_result = result
98
98
)
99
99
assert server .send_message .called
100
- assert result .data == {' test' : [1 , {'in' : 2 }]}
100
+ assert result .data == {" test" : [1 , {"in" : 2 }]}
You can’t perform that action at this time.
0 commit comments