Changeset View
Changeset View
Standalone View
Standalone View
swh/fuse/cache.py
Show All 17 Lines | |||||
import aiosqlite | import aiosqlite | ||||
import dateutil.parser | import dateutil.parser | ||||
from psutil import virtual_memory | from psutil import virtual_memory | ||||
from swh.fuse.fs.artifact import RevisionHistoryShardByDate | from swh.fuse.fs.artifact import RevisionHistoryShardByDate | ||||
from swh.fuse.fs.entry import FuseDirEntry, FuseEntry | from swh.fuse.fs.entry import FuseDirEntry, FuseEntry | ||||
from swh.fuse.fs.mountpoint import CacheDir, OriginDir | from swh.fuse.fs.mountpoint import CacheDir, OriginDir | ||||
from swh.model.exceptions import ValidationError | from swh.model.exceptions import ValidationError | ||||
from swh.model.identifiers import CoreSWHID, ObjectType | from swh.model.swhids import CoreSWHID, ObjectType | ||||
from swh.web.client.client import ORIGIN_VISIT, typify_json | from swh.web.client.client import ORIGIN_VISIT, typify_json | ||||
async def db_connect(conf: Dict[str, Any]) -> aiosqlite.Connection: | async def db_connect(conf: Dict[str, Any]) -> aiosqlite.Connection: | ||||
# In-memory (thus temporary) caching is useful for testing purposes | # In-memory (thus temporary) caching is useful for testing purposes | ||||
if conf.get("in-memory", False): | if conf.get("in-memory", False): | ||||
path = "file::memory:?cache=shared" | path = "file::memory:?cache=shared" | ||||
uri = True | uri = True | ||||
▲ Show 20 Lines • Show All 373 Lines • Show Last 20 Lines |