diff --git a/platformio/__init__.py b/platformio/__init__.py
index afa9e24d..6096e53a 100644
--- a/platformio/__init__.py
+++ b/platformio/__init__.py
@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-VERSION = (4, 3, 1)
+VERSION = (4, 3, "2a1")
 __version__ = ".".join([str(s) for s in VERSION])
 
 __title__ = "platformio"
diff --git a/platformio/proc.py b/platformio/proc.py
index 80e50201..1937b257 100644
--- a/platformio/proc.py
+++ b/platformio/proc.py
@@ -20,6 +20,7 @@ from threading import Thread
 
 from platformio import exception
 from platformio.compat import (
+    PY2,
     WINDOWS,
     get_filesystem_encoding,
     get_locale_encoding,
@@ -30,7 +31,10 @@ from platformio.compat import (
 class AsyncPipeBase(object):
     def __init__(self):
         self._fd_read, self._fd_write = os.pipe()
-        self._pipe_reader = os.fdopen(self._fd_read)
+        if PY2:
+            self._pipe_reader = os.fdopen(self._fd_read)
+        else:
+            self._pipe_reader = os.fdopen(self._fd_read, encoding="utf-8")
         self._buffer = ""
         self._thread = Thread(target=self.run)
         self._thread.start()