From 435d5207ab45a11eabbb85a6c52acf9fec993143 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B0=8F=E4=B9=88=E5=B0=8F=E5=84=BF=E9=83=8EEL?= Date: Wed, 22 Sep 2021 06:36:26 +0800 Subject: [PATCH] fix: use == instead of is when comparing with a certain types of literals (#26519) --- examples/python/async_streaming/client.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/examples/python/async_streaming/client.py b/examples/python/async_streaming/client.py index 28b7f5742ff..cb6eaf48767 100644 --- a/examples/python/async_streaming/client.py +++ b/examples/python/async_streaming/client.py @@ -66,9 +66,9 @@ class CallMaker: logging.info("Call toward [%s] enters [%s] state", self._phone_number, phone_pb2.CallState.State.Name(call_state)) self._call_state = call_state - if call_state is phone_pb2.CallState.State.ACTIVE: + if call_state == phone_pb2.CallState.State.ACTIVE: self._peer_responded.set() - if call_state is phone_pb2.CallState.State.ENDED: + if call_state == phone_pb2.CallState.State.ENDED: self._peer_responded.set() self._call_finished.set() @@ -80,13 +80,13 @@ class CallMaker: self._consumer_future = self._executor.submit(self._response_watcher, response_iterator) - def wait_peer(self) -> None: + def wait_peer(self) -> bool: logging.info("Waiting for peer to connect [%s]...", self._phone_number) self._peer_responded.wait(timeout=None) if self._consumer_future.done(): # If the future raises, forwards the exception here self._consumer_future.result() - return self._call_state is phone_pb2.CallState.State.ACTIVE + return self._call_state == phone_pb2.CallState.State.ACTIVE def audio_session(self) -> None: assert self._audio_session_link is not None