/
alexefan136
/
flowstack
Обзор
Документация
Войти
/
alexefan136
/
flowstack
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
main
core/engine/src/primitives/__init__.py
283 строки
7 KB
Alexander Efanov
upd fix
31 июл 2026, 19:17
31 июл 2026, 19:17
d146d86
Код
Авторство
О чём код?
""" Primitives — базовые типы и интерфейсы для FlowStack Engine. Этот модуль содержит фундаментальные примитивы, используемые по всему Engine: - Утилиты времени (``_time``): timezone-aware UTC, monotonic, парсинг дат - Безопасный eval (``_safe_eval``): замена ``eval()`` для условий flow - Контексты выполнения (``RunContext`` и его наследники) - Состояния (Agent, Flow, Session) - Задачи (Task, UserTask) - Скиллы (Skill, SkillTemplate) - Flows (Flow, FlowNode, FlowEdge) - Память (MemoryEntry, MemoryQuery) - Workspace (Workspace, WorkspaceMember) """ from __future__ import annotations # ============================================================================ # Safe expression evaluation (_safe_eval) # ============================================================================ from src.primitives._safe_eval import ( SafeEvalError, is_safe_expression, safe_eval, safe_eval_bool, ) # ============================================================================ # Time utilities (_time) # ============================================================================ from src.primitives._time import ( elapsed_ms, ensure_aware, format_relative_time, is_expired, is_overdue, monotonic, monotonic_ms, parse_datetime, to_iso, to_timestamp, utc_from_timestamp, utc_now, ) # ============================================================================ # Context # ============================================================================ from src.primitives.context import ( AgentContext, BudgetLimits, CancellationToken, CancelledError, MCPContext, RunContext, RunStatus, SkillContext, TaskContext, ) # ============================================================================ # Flow # ============================================================================ from src.primitives.flow import ( Flow, FlowContext, FlowEdge, FlowEdgeType, FlowMetadata, FlowNode, FlowNodeType, FlowResult, FlowRunner, FlowStatus, FlowStep, FlowValidator, ) # ============================================================================ # Memory # ============================================================================ from src.primitives.memory import ( MemoryContext, MemoryEntry, MemoryImportance, MemoryQuery, MemoryResult, MemoryScope, MemoryScorer, MemoryStore, MemorySummarizer, MemoryType, create_episodic_memory, create_long_term_memory, create_procedural_memory, create_semantic_memory, create_short_term_memory, create_user_profile_memory, ) # ============================================================================ # Skill # ============================================================================ from src.primitives.skill import ( Skill, SkillCategory, SkillExample, SkillParameter, SkillParameterType, SkillTemplate, create_boolean_parameter, create_number_parameter, create_select_parameter, create_skill_parameter, create_text_parameter, create_textarea_parameter, ) # ============================================================================ # State # ============================================================================ from src.primitives.state import ( AgentState, Checkpoint, EdgeStatus, ExecutionState, FlowState, NodeStatus, RetryStrategy, SessionState, StateEvent, StateManager, TaskStatus, create_agent_state, create_execution_state, create_flow_state, create_session_state, ) # ============================================================================ # Task # ============================================================================ from src.primitives.task import ( Task, TaskPriority, TaskRun, TaskRunStatus, TaskType, UserTask, UserTaskStatus, create_task, create_task_run, create_user_task, ) # ============================================================================ # Workspace # ============================================================================ from src.primitives.workspace import ( Workspace, WorkspaceMember, WorkspacePlan, WorkspaceQuotas, WorkspaceRole, WorkspaceSettings, WorkspaceStatus, WorkspaceUsage, create_workspace, create_workspace_member, ) # ============================================================================ # Version # ============================================================================ __version__ = "0.2.0" # ============================================================================ # Public API # ============================================================================ __all__ = [ "AgentContext", "AgentState", "BudgetLimits", "CancellationToken", "CancelledError", "Checkpoint", "EdgeStatus", "ExecutionState", "Flow", "FlowContext", "FlowEdge", "FlowEdgeType", "FlowMetadata", "FlowNode", "FlowNodeType", "FlowResult", "FlowRunner", "FlowStatus", "FlowStep", "FlowValidator", "MCPContext", "MemoryContext", "MemoryEntry", "MemoryImportance", "MemoryQuery", "MemoryResult", "MemoryScope", "MemoryScorer", "MemoryStore", "MemorySummarizer", "MemoryType", "NodeStatus", "RetryStrategy", "RunContext", "RunStatus", "SafeEvalError", "SessionState", "Skill", "SkillCategory", "SkillExample", "SkillParameter", "SkillParameterType", "SkillTemplate", "StateEvent", "StateManager", "Task", "TaskContext", "TaskPriority", "TaskRun", "TaskRunStatus", "TaskStatus", "TaskType", "UserTask", "UserTaskStatus", "Workspace", "WorkspaceMember", "WorkspacePlan", "WorkspaceQuotas", "WorkspaceRole", "WorkspaceSettings", "WorkspaceStatus", "WorkspaceUsage", "__version__", "create_agent_state", "create_boolean_parameter", "create_episodic_memory", "create_execution_state", "create_flow_state", "create_long_term_memory", "create_number_parameter", "create_procedural_memory", "create_select_parameter", "create_semantic_memory", "create_session_state", "create_short_term_memory", "create_skill_parameter", "create_task", "create_task_run", "create_text_parameter", "create_textarea_parameter", "create_user_profile_memory", "create_user_task", "create_workspace", "create_workspace_member", "elapsed_ms", "ensure_aware", "format_relative_time", "is_expired", "is_overdue", "is_safe_expression", "monotonic", "monotonic_ms", "parse_datetime", "safe_eval", "safe_eval_bool", "to_iso", "to_timestamp", "utc_from_timestamp", "utc_now", ]