Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commita9a173f

Browse files
Replace deprecated asyncio.iscoroutinefunction() call with inspect.iscoroutinefunction()
1 parentb4d9837 commita9a173f

File tree

5 files changed

+11
-9
lines changed

5 files changed

+11
-9
lines changed

‎dash/_callback.py‎

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,10 @@
11
importcollections
22
importhashlib
3+
importinspect
34
fromfunctoolsimportwraps
45

56
fromtypingimportCallable,Optional,Any,List,Tuple,Union,Dict
67

7-
8-
importasyncio
98
importflask
109

1110
from .dependenciesimport (
@@ -49,7 +48,7 @@ async def _async_invoke_callback(
4948
func,*args,**kwargs
5049
):# used to mark the frame for the debugger
5150
# Check if the function is a coroutine function
52-
ifasyncio.iscoroutinefunction(func):
51+
ifinspect.iscoroutinefunction(func):
5352
returnawaitfunc(*args,**kwargs)# %% callback invoked %%
5453
# If the function is not a coroutine, call it directly
5554
returnfunc(*args,**kwargs)# %% callback invoked %%
@@ -814,7 +813,7 @@ async def async_add_context(*args, **kwargs):
814813

815814
returnjsonResponse
816815

817-
ifasyncio.iscoroutinefunction(func):
816+
ifinspect.iscoroutinefunction(func):
818817
callback_map[callback_id]["callback"]=async_add_context
819818
else:
820819
callback_map[callback_id]["callback"]=add_context

‎dash/_jupyter.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -202,7 +202,7 @@ def capture_event(stream, ident, parent):
202202
if_jupyter_comm_response_received():
203203
break
204204

205-
ifasyncio.iscoroutinefunction(kernel.do_one_iteration):
205+
ifinspect.iscoroutinefunction(kernel.do_one_iteration):
206206
loop=asyncio.get_event_loop()
207207
nest_asyncio.apply(loop)
208208
loop.run_until_complete(kernel.do_one_iteration())

‎dash/background_callback/managers/celery_manager.py‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
importinspect
12
importjson
23
importtraceback
34
fromcontextvarsimportcopy_context
@@ -250,7 +251,7 @@ async def async_run():
250251
result_key,json.dumps(user_callback_output,cls=PlotlyJSONEncoder)
251252
)
252253

253-
ifasyncio.iscoroutinefunction(fn):
254+
ifinspect.iscoroutinefunction(fn):
254255
func=partial(ctx.run,async_run)
255256
asyncio.run(func())
256257
else:

‎dash/background_callback/managers/diskcache_manager.py‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
importinspect
12
importtraceback
23
fromcontextvarsimportcopy_context
34
importasyncio
@@ -296,7 +297,7 @@ async def async_run():
296297
exceptExceptionaserr:# pylint: disable=broad-except
297298
print(f"Diskcache manager couldn't save output:{err}")
298299

299-
ifasyncio.iscoroutinefunction(fn):
300+
ifinspect.iscoroutinefunction(fn):
300301
func=partial(ctx.run,async_run)
301302
asyncio.run(func())
302303
else:

‎dash/dash.py‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
importos
33
importsys
44
importcollections
5+
importinspect
56
importimportlib
67
importwarnings
78
fromcontextvarsimportcopy_context
@@ -220,7 +221,7 @@ def _do_skip(error):
220221

221222
asyncdefexecute_async_function(func,*args,**kwargs):
222223
# Check if the function is a coroutine function
223-
ifasyncio.iscoroutinefunction(func):
224+
ifinspect.iscoroutinefunction(func):
224225
returnawaitfunc(*args,**kwargs)
225226
# If the function is not a coroutine, call it directly
226227
returnfunc(*args,**kwargs)
@@ -837,7 +838,7 @@ async def _parse_body_async():
837838
return_parse_body_async
838839

839840
forpath,funcinself.callback_api_paths.items():
840-
ifasyncio.iscoroutinefunction(func):
841+
ifinspect.iscoroutinefunction(func):
841842
self._add_url(path,make_parse_body_async(func), ["POST"])
842843
else:
843844
self._add_url(path,make_parse_body(func), ["POST"])

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp