Searched refs:processing_on (Results 1 – 4 of 4) sorted by relevance
149 ws = ts.processing_on186 ws = ts.processing_on279 assert ts.processing_on == victim314 ts.processing_on = thief399 if ts not in self.key_stealable or ts.processing_on is not sat:432 sat = ts.processing_on
278 candidates -= {waiter_ts.processing_on for waiter_ts in ts.waiters}384 nwaiters = len({waiter.processing_on or waiter for waiter in ts.waiters})
1582 def processing_on(self) -> "WorkerState | None": member in TaskState1585 @processing_on.setter1586 def processing_on(self, v: WorkerState) -> None: member in TaskState
171 :attr:`TaskState.processing_on` ✓