ipython / ipython/ipykernel

interrupt issues with async code

オープン
#1,239 コメント 4 件 リアクション 0 件 担当者 1 名 @Carreau が担当を希望しています GitHub で見る
bug
主要言語
Python
スター
734
フォーク
412
平均マージ
1日 5時間
マージ済み PR(30日)
8

説明

Hi,

Aside from the now fixed #881, I still run into some async + interrupt issues. I'm not 100% sure if I need to do something differently or there is a way to do what we mean.

The following is not interrupted and always run to completion. If you sleep instead of httpx.get (or request.get), it works as expected.
```python
import asyncio
import httpx
from tqdm.asyncio import tqdm as tqdm_async

semaphore = asyncio.Semaphore(1)

x = 0
async def one_at_a_time():
global semaphore

async with semaphore:
global x
# await asyncio.sleep(1)
httpx.get('http://httpbin.org/delay/1')
x += 1
print(x)
return x

await tqdm_async.gather(*[one_at_a_time() for _ in range(10)])
```

Ideally, I want these to be tasks so I can cancel them. Again, interrupt has no effect:
```python
import asyncio
from time import sleep
from tqdm.asyncio import tqdm as tqdm_async

semaphore = asyncio.Semaphore(1)
x = 0
async def one_at_a_time():
global semaphore

async with semaphore:
global x
sleep(1)
x += 1
print(x)
return x

async def outer_async():
return await one_at_a_time()

await tqdm_async.gather(*[asyncio.create_task(one_at_a_time()) for _ in range(10)])
```

Any suggestions for how to fix my code to work better with ipykernel or how to fix ipykernel (or IPython) itself? Even better would be something that works on 6.x, but I think that may be challenging as even #881 is not fixed there.

コントリビューションガイド

コントリビューションガイドを開く

評価

この issue はまだ評価されていません。

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。