From 1088a9d1ccbb6e7ff2879c88578a772d7c56425d Mon Sep 17 00:00:00 2001 From: Hendrik Makait Date: Thu, 15 Jun 2023 17:06:34 +0200 Subject: [PATCH] Typo --- distributed/shuffle/_scheduler_extension.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/distributed/shuffle/_scheduler_extension.py b/distributed/shuffle/_scheduler_extension.py index 7045eb17f1..263ac4a8e9 100644 --- a/distributed/shuffle/_scheduler_extension.py +++ b/distributed/shuffle/_scheduler_extension.py @@ -314,7 +314,7 @@ def remove_worker(self, scheduler: Scheduler, worker: str) -> None: # TODO: Do we need to handle other states? # If processing the transactions causes a task to get released, this - # remove the shuffle from self.states. Therefore, we must process them + # removes the shuffle from self.states. Therefore, we must process them # outside of the loop. self.scheduler.transitions(recs, stimulus_id=stimulus_id)