|
2 | 2 |
|
3 | 3 | from lightning_utilities.core.imports import RequirementCache
|
4 | 4 |
|
5 |
| -_LIGHTNING_DATA_AVAILABLE = RequirementCache("lightning_data") |
| 5 | +_LITDATA_AVAILABLE = RequirementCache("litdata") |
6 | 6 | _LIGHTNING_SDK_AVAILABLE = RequirementCache("lightning_sdk")
|
7 | 7 |
|
8 |
| -if _LIGHTNING_DATA_AVAILABLE: |
9 |
| - import lightning_data |
| 8 | +if _LITDATA_AVAILABLE: |
| 9 | + import litdata |
10 | 10 |
|
11 | 11 | # Enable resolution at least for lower data namespace
|
12 |
| - sys.modules["lightning.data"] = lightning_data |
| 12 | + sys.modules["lightning.data"] = litdata |
13 | 13 |
|
14 |
| - from lightning_data.processing.functions import map, optimize, walk |
15 |
| - from lightning_data.streaming.combined import CombinedStreamingDataset |
16 |
| - from lightning_data.streaming.dataloader import StreamingDataLoader |
17 |
| - from lightning_data.streaming.dataset import StreamingDataset |
| 14 | + from litdata.processing.functions import map, optimize, walk |
| 15 | + from litdata.streaming.combined import CombinedStreamingDataset |
| 16 | + from litdata.streaming.dataloader import StreamingDataLoader |
| 17 | + from litdata.streaming.dataset import StreamingDataset |
18 | 18 |
|
19 | 19 | else:
|
20 |
| - # TODO: Delete all the code when everything is moved to lightning_data |
| 20 | + # TODO: Delete all the code when everything is moved to litdata |
21 | 21 | from lightning.data.processing.functions import map, optimize, walk
|
22 | 22 | from lightning.data.streaming.combined import CombinedStreamingDataset
|
23 | 23 | from lightning.data.streaming.dataloader import StreamingDataLoader
|
|
34 | 34 | "walk",
|
35 | 35 | ]
|
36 | 36 |
|
37 |
| -# TODO: Move this to lightning_data |
| 37 | +# TODO: Move this to litdata |
38 | 38 | if _LIGHTNING_SDK_AVAILABLE:
|
39 | 39 | from lightning_sdk import Machine # noqa: F401
|
40 | 40 |
|
|
0 commit comments