2
2
mostly functional tests of gateways.
3
3
"""
4
4
import os
5
+ from textwrap import dedent
6
+
5
7
import py
6
8
import pytest
7
9
import socket
@@ -110,19 +112,21 @@ def test_remote_exec_module(self, tmpdir, gw):
110
112
name = channel .receive ()
111
113
assert name == 2
112
114
113
- def test_remote_exec_module_with_traceback (self , gw , tmpdir ):
115
+ def test_remote_exec_module_with_traceback (self , gw , tmpdir , monkeypatch ):
114
116
remotetest = tmpdir .join ("remotetest.py" )
115
- remotetest .write (
116
- " \n def run_me(channel=None):\n raise ValueError('me') \n \n " +
117
- "if __name__ == '__channelexec__': \n run_me() \n " )
117
+ remotetest .write (dedent ( """
118
+ def run_me(channel=None):
119
+ raise ValueError('me' )
118
120
119
- try :
120
- sys .path .insert (0 , str (tmpdir ))
121
- module = __import__ ("remotetest" )
122
- finally :
123
- sys .path .pop (0 )
121
+ if __name__ == '__channelexec__':
122
+ run_me()
123
+ """ )
124
+ )
125
+
126
+ monkeypatch .syspath_prepend (tmpdir )
127
+ import remotetest
124
128
125
- ch = gw .remote_exec (module )
129
+ ch = gw .remote_exec (remotetest )
126
130
try :
127
131
ch .receive ()
128
132
except execnet .gateway_base .RemoteError as e :
@@ -131,7 +135,7 @@ def test_remote_exec_module_with_traceback(self, gw, tmpdir):
131
135
finally :
132
136
ch .close ()
133
137
134
- ch = gw .remote_exec (module .run_me )
138
+ ch = gw .remote_exec (remotetest .run_me )
135
139
try :
136
140
ch .receive ()
137
141
except execnet .gateway_base .RemoteError as e :
0 commit comments