5
5
6
6
from superduper import logging
7
7
from superduper .backends .base .cluster import Cluster
8
- from superduper .backends .local .cache import LocalCache
9
8
from superduper .backends .local .cdc import LocalCDCBackend
10
- from superduper .backends .simple .compute import SimpleComputeBackend , SimpleComputeClient
9
+ from superduper .backends .simple .compute import SimpleComputeClient
11
10
from superduper .backends .local .crontab import LocalCrontabBackend
12
11
from superduper .backends .simple .scheduler import SimpleScheduler
13
12
from superduper .backends .local .vector_search import LocalVectorSearchBackend
@@ -29,15 +28,8 @@ class SimpleCluster(Cluster):
29
28
def build (cls , CFG , ** kwargs ):
30
29
"""Build the local cluster."""
31
30
searcher_impl = load_plugin (CFG .vector_search_engine ).VectorSearcher
32
- cache = None
33
- if CFG .cache and CFG .cache .startswith ('redis' ):
34
- cache = load_plugin ('redis' ).Cache (uri = CFG .cache )
35
- elif CFG .cache :
36
- assert CFG .cache == 'in-process'
37
- cache = LocalCache ()
38
31
39
32
return SimpleCluster (
40
- cache = cache ,
41
33
scheduler = SimpleScheduler (),
42
34
compute = SimpleComputeClient (),
43
35
vector_search = LocalVectorSearchBackend (searcher_impl = searcher_impl ),
@@ -52,9 +44,7 @@ def drop(self, force: bool = False):
52
44
"""
53
45
if not force :
54
46
if not click .confirm (
55
- "Are you sure you want to drop the cache ? " ,
47
+ "Are you sure you want to drop the cluster ? " ,
56
48
default = False ,
57
49
):
58
- logging .warn ("Aborting..." )
59
- if self .cache is not None :
60
- return self .cache .drop ()
50
+ logging .warn ("Aborting..." )
0 commit comments