fix lint

ray-project · Sep 17, 2024 · 9b848cd · 9b848cd
1 parent 9a25a5c
commit 9b848cd
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/python/ray/data/_internal/execution/streaming_executor.py b/python/ray/data/_internal/execution/streaming_executor.py
@@ -354,9 +354,11 @@ def _consumer_idling(self) -> bool:
         return len(self._output_node.outqueue) == 0
 
     def _report_current_usage(self) -> None:
-        # running_usage is the amount of resources that have been requested but not necessarily available
+        # running_usage is the amount of resources that have been requested but
+        # not necessarily available
         # TODO(sofian) https://github.com/ray-project/ray/issues/47520
-        # We need to split the reported resources into running, pending-scheduling, pending-node-assignment.
+        # We need to split the reported resources into running, pending-scheduling,
+        # pending-node-assignment.
         running_usage = self._resource_manager.get_global_running_usage()
         pending_usage = self._resource_manager.get_global_pending_usage()
         limits = self._resource_manager.get_global_limits()