Skip to content

Commit

Permalink
to_yaml -> to_yamls
Browse files Browse the repository at this point in the history
  • Loading branch information
sjperkins committed Mar 17, 2022
1 parent 1ecb088 commit 4b65b81
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion distributed/cluster_dump.py
Original file line number Diff line number Diff line change
Expand Up @@ -248,7 +248,7 @@ def _compact_state(self, state: dict, expand_keys: set[str]):
result["general"] = general
return result

def to_yaml(
def to_yamls(
self,
root_dir: str | Path | None = None,
worker_expand_keys: Collection[str] = ("config", "log", "logs", "tasks"),
Expand Down
4 changes: 2 additions & 2 deletions distributed/tests/test_cluster_dump.py
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,7 @@ def _expected_story(task_key):


@gen_cluster(client=True)
async def test_cluster_dump_to_yaml(c, s, a, b, tmp_path):
async def test_cluster_dump_to_yamls(c, s, a, b, tmp_path):
futs = c.map(inc, range(2))
await c.gather(futs)

Expand All @@ -172,7 +172,7 @@ async def test_cluster_dump_to_yaml(c, s, a, b, tmp_path):

dump = DumpArtefact.from_url(f"{filename}.msgpack.gz")
yaml_path = Path(tmp_path / "dump")
dump.to_yaml(yaml_path)
dump.to_yamls(yaml_path)

scheduler_files = {
"events.yaml",
Expand Down

0 comments on commit 4b65b81

Please sign in to comment.