diff --git a/confluent_client/confluent/termhandler.py b/confluent_client/confluent/termhandler.py
index 32304aec..0b3b0d16 100644
--- a/confluent_client/confluent/termhandler.py
+++ b/confluent_client/confluent/termhandler.py
@@ -59,10 +59,10 @@ class TermHandler(object):
                     winid = os.environ['WINDOWID']
                     if not isinstance(winid, bytes):
                         winid = winid.encode('utf8')
-                    connection.sendall(os.environ['WINDOWID'])
+                    connection.sendall(winid)
                 connection.close()
             except BaseException:
                 pass
             finally:
                 if connection is not None:
-                    connection.close()
\ No newline at end of file
+                    connection.close()