Coverage for astrocyte/pipeline/__init__.py: 100%

1"""Astrocyte built-in intelligence pipeline. 

2 

3Active when ``provider_tier = "storage"`` — the framework owns retain/recall 

4over storage adapters. Steps aside when ``provider_tier = "engine"`` so a 

5full-stack engine provider (Mem0, Zep, Mystique) owns the pipeline instead. 

6See docs/_design/built-in-pipeline.md. 

7""" 

8 

9from astrocyte.pipeline.extraction import ( 

10 BUILTIN_EXTRACTION_PROFILES, 

11 ChunkingDecision, 

12 PreparedRetainInput, 

13 extraction_profile_for_source, 

14 merged_extraction_profiles, 

15 merged_user_and_builtin_profiles, 

16 prepare_retain_input, 

17 resolve_retain_chunking, 

18 resolve_retain_fact_type, 

19) 

20from astrocyte.pipeline.tasks import ( 

21 COMPILE_BANK, 

22 COMPILE_PERSONA_PAGE, 

23 INDEX_WIKI_PAGE_VECTOR, 

24 LINT_WIKI_PAGE, 

25 NORMALIZE_TEMPORAL_FACTS, 

26 PROJECT_ENTITY_EDGES, 

27 InMemoryTaskBackend, 

28 MemoryTask, 

29 MemoryTaskDispatcher, 

30 MemoryTaskWorker, 

31 TaskHandlerContext, 

32) 

33 

34try: 

35 from astrocyte.pipeline.pgqueuer_tasks import PgQueuerMemoryTaskQueue 

36except ImportError: # pragma: no cover - optional worker extra 

37 PgQueuerMemoryTaskQueue = None # type: ignore[assignment] 

38 

39__all__ = [ 

40 "BUILTIN_EXTRACTION_PROFILES", 

41 "COMPILE_BANK", 

42 "COMPILE_PERSONA_PAGE", 

43 "INDEX_WIKI_PAGE_VECTOR", 

44 "LINT_WIKI_PAGE", 

45 "NORMALIZE_TEMPORAL_FACTS", 

46 "PROJECT_ENTITY_EDGES", 

47 "ChunkingDecision", 

48 "InMemoryTaskBackend", 

49 "MemoryTask", 

50 "MemoryTaskDispatcher", 

51 "MemoryTaskWorker", 

52 "PgQueuerMemoryTaskQueue", 

53 "PreparedRetainInput", 

54 "TaskHandlerContext", 

55 "extraction_profile_for_source", 

56 "merged_extraction_profiles", 

57 "merged_user_and_builtin_profiles", 

58 "prepare_retain_input", 

59 "resolve_retain_chunking", 

60 "resolve_retain_fact_type", 

61]