state

Author: RonnyPfannschmidt

pyproject.toml

@@ -69,3 +69,4 @@ include = [
 
 [tool.mypy]
 python_version = "3.8"
+mypy_path = "$MYPY_CONFIG_FILE_DIR/src"

src/execnet/gateway_base.py

@@ -166,6 +166,9 @@ def get_ident(self):
 
     def sleep(self, delay):
         import eventlet
+# f = open("/tmp/execnet-%s" % os.getpid(), "w")
+# def log_extra(*msg):
+#     f.write(" ".join([str(x) for x in msg]) + "\n")
 
         eventlet.sleep(delay)
 

src/execnet/gateway_bootstrap.py

@@ -2,6 +2,7 @@
 code to initialize the remote side of a gateway once the io is created
 """
 import inspect
+import json
 import os
 
 import execnet
@@ -23,13 +24,13 @@ def bootstrap_import(io, spec):
     sendexec(
         io,
         "import sys",
-        "if %r not in sys.path:" % importdir,
-        "    sys.path.insert(0, %r)" % importdir,
+        f"if {importdir!r} not in sys.path:",
+        f"    sys.path.insert(0, {importdir!r})",
         "from execnet.gateway_base import serve, init_popen_io, get_execmodel",
         "sys.stdout.write('1')",
         "sys.stdout.flush()",
-        "execmodel = get_execmodel(%r)" % spec.execmodel,
-        "serve(init_popen_io(execmodel), id='%s-worker')" % spec.id,
+        f"execmodel = get_execmodel({spec.execmodel!r})",
+        f"serve(init_popen_io(execmodel), id='{spec.id}-worker')",
     )
     s = io.read(1)
     assert s == b"1", repr(s)
@@ -75,7 +76,8 @@ def bootstrap_socket(io, id):
 
 def sendexec(io, *sources):
     source = "\n".join(sources)
-    io.write((repr(source) + "\n").encode("utf-8"))
+    encoded = (json.dumps(source) + "\n").encode("utf-8")
+    io.write(encoded)
 
 
 def bootstrap(io, spec):

src/execnet/gateway_io.py

@@ -40,7 +40,7 @@ def killpopen(popen):
         sys.stderr.flush()
 
 
-popen_bootstrapline = "import sys;exec(eval(sys.stdin.readline()))"
+popen_bootstrapline = "import sys;import json;exec(json.loads(sys.stdin.readline()))"
 
 
 def shell_split_path(path):

testing/test_basics.py

@@ -1,6 +1,7 @@
 from __future__ import annotations
 
 import inspect
+import json
 import os
 import subprocess
 import sys
@@ -85,7 +86,9 @@ def receive():
 
     try:
         source = inspect.getsource(read_write_loop) + "read_write_loop()"
-        send(repr(source) + "\n")
+        repr_source = json.dumps(source) + "\n"
+        sendline = repr_source
+        send(sendline)
         s = receive()
         assert s == "ok\n"
         send("hello\n")