File tree Expand file tree Collapse file tree 3 files changed +9
-9
lines changed Expand file tree Collapse file tree 3 files changed +9
-9
lines changed Original file line number Diff line number Diff line change @@ -231,7 +231,7 @@ async def get_version(
231
231
try :
232
232
doc = await anext (cursor )
233
233
return AsyncGridOut (self ._collection , file_document = doc , session = session )
234
- except ( StopIteration , StopAsyncIteration ) :
234
+ except StopAsyncIteration :
235
235
raise NoFile ("no version %d for filename %r" % (version , filename )) from None
236
236
237
237
async def get_last_version (
Original file line number Diff line number Diff line change @@ -75,20 +75,20 @@ def run(self):
75
75
assert data == b"hello"
76
76
else :
77
77
78
- class JustWrite ( asyncio . Task ) :
78
+ class JustWrite :
79
79
def __init__ (self , fs , n ):
80
80
async def run ():
81
81
for _ in range (self .n ):
82
82
file = self .fs .new_file (filename = "test" )
83
83
await file .write (b"hello" )
84
84
await file .close ()
85
85
86
- asyncio .Task . __init__ ( self , run ())
86
+ self . task = asyncio .create_task ( run ())
87
87
self .fs = fs
88
88
self .n = n
89
89
self .daemon = True
90
90
91
- class JustRead ( asyncio . Task ) :
91
+ class JustRead :
92
92
def __init__ (self , fs , n , results ):
93
93
async def run ():
94
94
for _ in range (self .n ):
@@ -97,7 +97,7 @@ async def run():
97
97
self .results .append (data )
98
98
assert data == b"hello"
99
99
100
- asyncio .Task . __init__ ( self , run ())
100
+ self . task = asyncio .create_task ( run ())
101
101
self .fs = fs
102
102
self .n = n
103
103
self .results = results
Original file line number Diff line number Diff line change @@ -75,20 +75,20 @@ def run(self):
75
75
assert data == b"hello"
76
76
else :
77
77
78
- class JustWrite ( asyncio . Task ) :
78
+ class JustWrite :
79
79
def __init__ (self , fs , n ):
80
80
def run ():
81
81
for _ in range (self .n ):
82
82
file = self .fs .new_file (filename = "test" )
83
83
file .write (b"hello" )
84
84
file .close ()
85
85
86
- asyncio .Task . __init__ ( self , run ())
86
+ self . task = asyncio .create_task ( run ())
87
87
self .fs = fs
88
88
self .n = n
89
89
self .daemon = True
90
90
91
- class JustRead ( asyncio . Task ) :
91
+ class JustRead :
92
92
def __init__ (self , fs , n , results ):
93
93
def run ():
94
94
for _ in range (self .n ):
@@ -97,7 +97,7 @@ def run():
97
97
self .results .append (data )
98
98
assert data == b"hello"
99
99
100
- asyncio .Task . __init__ ( self , run ())
100
+ self . task = asyncio .create_task ( run ())
101
101
self .fs = fs
102
102
self .n = n
103
103
self .results = results
You can’t perform that action at this time.
0 commit comments