We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent df30dbf commit 170670fCopy full SHA for 170670f
distributed/client.py
@@ -3095,8 +3095,12 @@ def _get_computation_code(
3095
module_name = fr.f_back.f_globals["__name__"] # type: ignore
3096
if module_name == "__channelexec__":
3097
break # execnet; pytest-xdist # pragma: nocover
3098
+ try:
3099
+ module_name = sys.modules[module_name].__name__
3100
+ except KeyError:
3101
+ # Ignore pathological cases where the module name isn't in `sys.modules`
3102
+ break
3103
# Ignore IPython related wrapping functions to user code
- module_name = sys.modules[module_name].__name__
3104
if module_name.endswith("interactiveshell"):
3105
break
3106
0 commit comments