我正在尝试让工作人员从他们的ipython内核输出一些信息,并在ipython会话中执行各种命令。我尝试了文档中的示例和ipyparallel示例,但没有尝试第二个示例(使用ipython magics)。我无法让工作人员执行任何命令。例如,我被以下问题卡住了:
from dask.distributed import Client
client = Client()
info = client.start_ipython_workers()
list_workers = info.keys()
%remote info[list_workers[0]]最后一行返回一个错误:
---------------------------------------------------------------------------
NameError Traceback (most recent call last)
<ipython-input-19-9118451af441> in <module>
----> 1 get_ipython().run_line_magic('remote', "info['tcp://127.0.0.1:50497'] worker.active")
~/miniconda/envs/dask/lib/python3.7/site-packages/IPython/core/interactiveshell.py in run_line_magic(self, magic_name, line, _stack_depth)
2334 kwargs['local_ns'] = self.get_local_scope(stack_depth)
2335 with self.builtin_trap:
-> 2336 result = fn(*args, **kwargs)
2337 return result
2338
~/miniconda/envs/dask/lib/python3.7/site-packages/distributed/_ipython_utils.py in remote_magic(line, cell)
115 info_name = split_line[0]
116 if info_name not in ip.user_ns:
--> 117 raise NameError(info_name)
118 connection_info = dict(ip.user_ns[info_name])
119
NameError: info['tcp://127.0.0.1:50497']对于如何从运行在workers上的ipython内核获取任何信息,我将不胜感激。
发布于 2021-02-20 01:52:38
在这里发帖只是为了跟踪,我在GitHub上提出了一个问题:https://github.com/dask/distributed/issues/4522
https://stackoverflow.com/questions/66167619
复制相似问题