diff --git a/python/ray/data/_internal/execution/streaming_executor.py b/python/ray/data/_internal/execution/streaming_executor.py index 238f6f9421cc..2bf7d185961a 100644 --- a/python/ray/data/_internal/execution/streaming_executor.py +++ b/python/ray/data/_internal/execution/streaming_executor.py @@ -363,9 +363,14 @@ def _report_current_usage(self) -> None: pending_usage = self._resource_manager.get_global_pending_usage() limits = self._resource_manager.get_global_limits() resources_status = ( - # TODO(scottjlee): Add dataset name/ID to progress bar output. - "Running Dataset. Active & requested resources: " - f"{running_usage.cpu:.4g}/{limits.cpu:.4g} CPU, " + "Active & requested resources: " + f"{running_usage.cpu:.4g} of {limits.cpu:.4g} available CPU, " + f"{running_usage.gpu:.4g} of {limits.gpu:.4g} available GPU, " + f"{running_usage.object_store_memory_str()} of " + f"{limits.object_store_memory_str()} available object_store_memory " + "(pending: " + f"{pending_usage.cpu:.4g} CPU, " + f"{pending_usage.gpu:.4g} GPU)" ) if running_usage.gpu > 0: resources_status += f"{running_usage.gpu:.4g}/{limits.gpu:.4g} GPU, "