From fda8e1f999c9ec467cd982861bef2e6d98a94baa Mon Sep 17 00:00:00 2001 From: Deependu Date: Mon, 4 Aug 2025 11:56:42 +0530 Subject: [PATCH 1/3] nitpick: remove asyncio from requirement.txt --- requirements/extras.txt | 1 - 1 file changed, 1 deletion(-) diff --git a/requirements/extras.txt b/requirements/extras.txt index 3cbb661ff..73561f503 100644 --- a/requirements/extras.txt +++ b/requirements/extras.txt @@ -6,4 +6,3 @@ lightning-sdk==2025.8.1 # Must be pinned to ensure compatibility google-cloud-storage polars fsspec -asyncio From 72f981dd03370e4e57940907d2214c07aeb252da Mon Sep 17 00:00:00 2001 From: Deependu Jha Date: Mon, 4 Aug 2025 13:37:09 +0530 Subject: [PATCH 2/3] update --- tests/streaming/test_dataset.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/streaming/test_dataset.py b/tests/streaming/test_dataset.py index 027b73f9a..5f86d1c4d 100644 --- a/tests/streaming/test_dataset.py +++ b/tests/streaming/test_dataset.py @@ -1022,7 +1022,7 @@ def _get_simulated_s3_dataloader(cache_dir, data_dir, shuffle=False): @pytest.mark.skipif(sys.platform == "win32", reason="Not tested on windows and MacOs") @mock.patch.dict(os.environ, {}, clear=True) -@pytest.mark.timeout(60) +@pytest.mark.timeout(120) @pytest.mark.parametrize("shuffle", [True, False]) def test_dataset_resume_on_future_chunks(shuffle, tmpdir, monkeypatch): """Tests resuming from a chunk past the first chunk, when subsequent chunks don't have the same size.""" From b9ec01ae89b98d60ac5a314409005c0ad7f79b3d Mon Sep 17 00:00:00 2001 From: Deependu Jha Date: Mon, 4 Aug 2025 13:38:00 +0530 Subject: [PATCH 3/3] update --- tests/streaming/test_dataset.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/streaming/test_dataset.py b/tests/streaming/test_dataset.py index 5f86d1c4d..c3c3ff806 100644 --- a/tests/streaming/test_dataset.py +++ b/tests/streaming/test_dataset.py @@ -1022,7 +1022,7 @@ def _get_simulated_s3_dataloader(cache_dir, data_dir, shuffle=False): @pytest.mark.skipif(sys.platform == "win32", reason="Not tested on windows and MacOs") @mock.patch.dict(os.environ, {}, clear=True) -@pytest.mark.timeout(120) +@pytest.mark.timeout(90) @pytest.mark.parametrize("shuffle", [True, False]) def test_dataset_resume_on_future_chunks(shuffle, tmpdir, monkeypatch): """Tests resuming from a chunk past the first chunk, when subsequent chunks don't have the same size."""