Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 0 additions & 13 deletions torch_geometric/distributed/__init__.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,3 @@
from warnings import warn

from .dist_context import DistContext
from .local_feature_store import LocalFeatureStore
from .local_graph_store import LocalGraphStore
Expand All @@ -9,17 +7,6 @@
from .dist_neighbor_loader import DistNeighborLoader
from .dist_link_neighbor_loader import DistLinkNeighborLoader

warn(
"`torch_geometric.distributed` has been deprecated since 2.7.0 and will "
"no longer be maintained. For distributed training, refer to our "
"tutorials on distributed training at "
"https://pytorch-geometric.readthedocs.io/en/latest/tutorial/distributed.html " # noqa: E501
"or cuGraph examples at "
"https://github.com/rapidsai/cugraph-gnn/tree/main/python/cugraph-pyg/cugraph_pyg/examples", # noqa: E501
stacklevel=2,
category=DeprecationWarning,
)

__all__ = classes = [
'DistContext',
'LocalFeatureStore',
Expand Down
10 changes: 10 additions & 0 deletions torch_geometric/distributed/dist_link_neighbor_loader.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
from typing import Callable, Dict, List, Optional, Tuple, Union
from warnings import warn

import torch

Expand Down Expand Up @@ -93,6 +94,15 @@ def __init__(
channel=channel,
concurrency=concurrency,
)
else:
warn(
"`torch_geometric.distributed` has been deprecated since 2.7.0 and will " # noqa: E501
"no longer be maintained. For distributed training, refer to our " # noqa: E501
"tutorials on distributed training at "
"https://pytorch-geometric.readthedocs.io/en/latest/tutorial/distributed.html " # noqa: E501
"or cuGraph examples at "
"https://github.com/rapidsai/cugraph-gnn/tree/main/python/cugraph-pyg/cugraph_pyg/examples", # noqa: E501
)

DistLoader.__init__(
self,
Expand Down
10 changes: 10 additions & 0 deletions torch_geometric/distributed/dist_neighbor_loader.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
from typing import Callable, Dict, List, Optional, Tuple, Union
from warnings import warn

import torch

Expand Down Expand Up @@ -86,6 +87,15 @@ def __init__(
channel=channel,
concurrency=concurrency,
)
else:
warn(
"`torch_geometric.distributed` has been deprecated since 2.7.0 and will " # noqa: E501
"no longer be maintained. For distributed training, refer to our " # noqa: E501
"tutorials on distributed training at "
"https://pytorch-geometric.readthedocs.io/en/latest/tutorial/distributed.html " # noqa: E501
"or cuGraph examples at "
"https://github.com/rapidsai/cugraph-gnn/tree/main/python/cugraph-pyg/cugraph_pyg/examples", # noqa: E501
)

DistLoader.__init__(
self,
Expand Down
9 changes: 9 additions & 0 deletions torch_geometric/distributed/dist_neighbor_sampler.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
import logging
import math
from typing import Any, Callable, Dict, List, Optional, Tuple, Union
from warnings import warn

import numpy as np
import torch
Expand Down Expand Up @@ -81,6 +82,14 @@ def __init__(
device: Optional[torch.device] = None,
**kwargs,
):
warn(
"`torch_geometric.distributed` has been deprecated since 2.7.0 and will " # noqa: E501
"no longer be maintained. For distributed training, refer to our " # noqa: E501
"tutorials on distributed training at "
"https://pytorch-geometric.readthedocs.io/en/latest/tutorial/distributed.html " # noqa: E501
"or cuGraph examples at "
"https://github.com/rapidsai/cugraph-gnn/tree/main/python/cugraph-pyg/cugraph_pyg/examples", # noqa: E501
)
self.current_ctx = current_ctx

self.feature_store, self.graph_store = data
Expand Down
2 changes: 1 addition & 1 deletion torch_geometric/llm/utils/feature_store.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
from torch import Tensor

from torch_geometric.data import Data, HeteroData
from torch_geometric.distributed import LocalFeatureStore
from torch_geometric.distributed.local_feature_store import LocalFeatureStore
from torch_geometric.llm.utils.backend_utils import batch_knn
from torch_geometric.sampler import HeteroSamplerOutput, SamplerOutput
from torch_geometric.typing import InputNodes
Expand Down
2 changes: 1 addition & 1 deletion torch_geometric/llm/utils/graph_store.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
from torch import Tensor

from torch_geometric.data import FeatureStore
from torch_geometric.distributed import LocalGraphStore
from torch_geometric.distributed.local_graph_store import LocalGraphStore
from torch_geometric.sampler import (
BidirectionalNeighborSampler,
NodeSamplerInput,
Expand Down
Loading