Skip to content

Commit 1cd602b

Browse files
committed
deprecate await Client() in favour of async with Client()
see also: - dask#6785 - dask#6201
1 parent d6160c8 commit 1cd602b

File tree

1 file changed

+12
-1
lines changed

1 file changed

+12
-1
lines changed

distributed/client.py

+12-1
Original file line numberDiff line numberDiff line change
@@ -764,6 +764,7 @@ class Client(SyncMethodMixin):
764764

765765
preloads: list[preloading.Preload]
766766
__loop: IOLoop | None = None
767+
__aentering = False
767768

768769
def __init__(
769770
self,
@@ -1133,6 +1134,12 @@ def start(self, **kwargs):
11331134
sync(self.loop, self._start, **kwargs)
11341135

11351136
def __await__(self):
1137+
if not self.__aentering:
1138+
warnings.warn(
1139+
"await Client() is deprecated, use async with Client():",
1140+
DeprecationWarning,
1141+
stacklevel=2,
1142+
)
11361143
if hasattr(self, "_started"):
11371144
return self._started.__await__()
11381145
else:
@@ -1379,7 +1386,11 @@ def __enter__(self):
13791386
return self
13801387

13811388
async def __aenter__(self):
1382-
await self
1389+
self.__aentering = True
1390+
try:
1391+
await self
1392+
finally:
1393+
self.__aentering = False
13831394
return self
13841395

13851396
async def __aexit__(self, exc_type, exc_value, traceback):

0 commit comments

Comments
 (0)