Skip to content

Conversation

@jrbourbeau
Copy link
Member

@jrbourbeau jrbourbeau commented Aug 23, 2021

psutil.disk_io_counters() returns None on diskless machines. This PR ensures we handle that case in our system monitor.

@jrbourbeau
Copy link
Member Author

There are a couple of unrelated test failures which I suspect are related to the recent changes in #5120

  File "/Users/runner/work/distributed/distributed/distributed/core.py", line 502, in handle_comm
    result = await result
  File "/Users/runner/work/distributed/distributed/distributed/scheduler.py", line 4327, in add_worker
    await self.handle_worker(comm=comm, worker=address)
  File "/Users/runner/work/distributed/distributed/distributed/scheduler.py", line 5445, in handle_worker
    await self.handle_stream(comm=comm, extra={"worker": worker})
  File "/Users/runner/work/distributed/distributed/distributed/core.py", line 575, in handle_stream
    handler(**merge(extra, msg))
  File "/Users/runner/work/distributed/distributed/distributed/scheduler.py", line 5320, in handle_task_finished
    r: tuple = self.stimulus_task_finished(key=key, worker=worker, **msg)
  File "/Users/runner/work/distributed/distributed/distributed/scheduler.py", line 4716, in stimulus_task_finished
    r: tuple = parent._transition(key, "memory", worker=worker, **kwargs)
  File "/Users/runner/work/distributed/distributed/distributed/scheduler.py", line 2248, in _transition
    for plugin in self.plugins.values():
RuntimeError: dictionary changed size during iteration

cc @douglasdavis

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant