update

Author: thomas

src/lightning/data/streaming/dataset.py

@@ -78,7 +78,7 @@ def __init__(
         if self.distributed_env.world_size > 1:
             if drop_last is False:
                 logger.warn(
-                    "You're operating within a distributed environment and have enabled the `drop_last` option. "
+                    "You're operating within a distributed environment and have disabled the `drop_last` option. "
                     "Please note that this configuration may lead to training interruptions if your system depends "
                     "on distributed collectives."
                 )

tests/tests_data/streaming/test_dataset.py

@@ -902,5 +902,5 @@ def detect(cls):
     assert not dataset.drop_last
 
     warn_value = logger_mock.warn._mock_mock_calls[0].args[0]
-    assert warn_value == "You're operating within a distributed environment and have enabled the `drop_last`" \
+    assert warn_value == "You're operating within a distributed environment and have disabled the `drop_last`" \
         " option. Please note that this configuration may lead to training interruptions if your system depends on distributed collectives."   # noqa: E501