typo

Author: divyanshk

torchdata/nodes/map.py

@@ -485,7 +485,7 @@ class _SingleThreadedMapper(Iterator[T]):
     - any other item: return the item
 
     A Bounded semaphore is used to limit concurrency and memory utilization.
-    If N items have been pulled from the source (i.e. acquire the semaphones),
+    If N items have been pulled from the source (i.e. acquire the semaphore),
     and M items have been yielded by this iterator (i.e. release the semaphore),
     we maintain the invariant that semaphore.value + (M - N) == prefetch_factor (modulo
     non-atomicness of operations).

torchdata/nodes/snapshot_store.py

@@ -58,6 +58,7 @@ def append(self, snapshot: Any, version: int) -> None:
     def pop_version(self, version: int) -> Optional[Any]:
         ver, val = None, None
         with self._lock:
+            # pop all items that have a lesser version index
             while self._q.queue and version >= self._q.queue[0][0]:
                 ver, val = self._q.get_nowait()