[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci
This commit is contained in:
pre-commit-ci[bot]
2025-11-07 08:18:23 +00:00
parent 40b6a914f3
commit 6f7e8595fc
2 changed files with 5 additions and 2 deletions

View File

@@ -65,7 +65,10 @@ class Distributor:
self.profiler.exit(f"sync_model_consumer_pp_{i}")
self.weight_version[i] += 1
if all(
[signal.get(f"producer_{self.distributor_id}_pp_{i}", None) == "ready_sync_model" for i in range(self.consumer_pp_size)]
[
signal.get(f"producer_{self.distributor_id}_pp_{i}", None) == "ready_sync_model"
for i in range(self.consumer_pp_size)
]
):
for i in range(self.consumer_pp_size):
self.profiler.enter(f"sync_model_producer_{self.distributor_id}_pp_{i}")

View File

@@ -1,2 +1,2 @@
ray==2.49.2
pygloo>=0.2.0 # you need to build from source: https://github.com/ray-project/pygloo commit 82ae2d72222aefcac54a8e88995735ede3abe9cf https://github.com/ray-project/pygloo/blob/main/README.md
pygloo>=0.2.0 # you need to build from source: https://github.com/ray-project/pygloo commit 82ae2d72222aefcac54a8e88995735ede3abe9cf https://github.com/ray-project/pygloo/blob/main/README.md