beam-core 0.2.0

Shared core types and workflow/session logic for beam
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

pub mod api;
pub mod ask;
pub mod config;
pub mod i18n;
pub mod ipc;
pub mod paths;
pub mod permissions;
pub mod schedule_parser;
pub mod schedule_store;
pub mod session;
pub mod workflow;
pub mod workflow_actions;
pub mod workflow_binding;
pub mod workflow_cold_scan;
pub mod workflow_definition;
pub mod workflow_orchestrator;
pub mod workflow_output;
pub mod workflow_projection;
pub mod workflow_resume;
pub mod workflow_run;
pub mod workflow_runtime;
pub mod workflow_sidecar;
pub mod workflow_snapshot;

pub use api::{
    AdoptCandidate, AdoptTmuxSessionRequest, ApiHealth, AttemptResumeEndResponse,
    AttemptResumeRequest, AttemptResumeStartResponse, BotSummary, CreateSessionRequest,
    DaemonOverview, DaemonRuntimeState, FinalOutputRequest, RestartSessionRequest,
    ResumeSessionRequest, SessionGroup, SessionInputRequest, SessionLocateInfo, SessionSummary,
    TerminalInfo,
};
pub use ask::{AskOption, AskQuestion, AskRequest, AskResult, legacy_selected};
pub use config::{
    BackendType, BotConfig, Config, DaemonConfig, LarkConfig, MessageQuotaConfig,
    OncallChatBinding, QuotaEntry, ScreenAnalyzerConfig, WebConfig,
};
pub use ipc::{
    CliUsageLimitKind, CliUsageLimitState, DaemonToWorker, DisplayMode, FinalOutputKind,
    InitConfig, ScreenStatus, TermActionKey, TuiPromptOption, WorkerToDaemon,
};
pub use paths::BeamPaths;
pub use permissions::{
    TalkEvaluation, TalkReason, can_operate, evaluate_talk, get_owner_open_id, grant_restricted,
    is_owner,
};
pub use schedule_parser::{ParsedNaturalSchedule, parse_natural_schedule, parse_schedule};
pub use schedule_store::{
    CreateTaskInput, ParsedSchedule, ParsedScheduleKind, ScheduleChatType, ScheduleDeliver,
    ScheduleRepeat, ScheduleStoreError, ScheduleTaskUpdate, ScheduledTask, append_output_log,
    create_task, get_task, list_tasks, mark_run, remove_task, update_task,
};
pub use session::{
    AdoptedFrom, ChatMode, PendingResponseCardState, Session, SessionScope, SessionStatus,
};
pub use workflow::{EventDraft, EventLog, WorkflowActor, WorkflowEventEnvelope};
pub use workflow_actions::{
    CompleteActivityCancelInput, CompleteNodeCancelInput, CompleteRunCancelInput, CreateWaitInput,
    DeliverCancelInput, ExpireWaitInput, RequestCancelInput, ResolveWaitInput, WaitKind,
    WaitOnTimeout, WaitResolution, complete_activity_cancel, complete_node_cancel,
    complete_run_cancel, create_wait, deliver_cancel, expire_wait, request_cancel, resolve_wait,
};
pub use workflow_binding::{
    BindingContext, BindingError, LoopContext, resolve_bindings, resolve_bound_string,
};
pub use workflow_cold_scan::{ColdScanStats, ColdWorkflowRun, scan_cold_workflow_runs};
pub use workflow_definition::{
    DecisionNode, HostExecutorNode, HumanGate, LoopNode, LoopOutputProjection, LoopTerminate,
    ParamDef, RetryPolicy, SubagentNode, WorkflowDefaults, WorkflowDefinition, WorkflowNode,
    parse_workflow_definition,
};
pub use workflow_orchestrator::{OrchestratorAction, decide_next_actions, topological_order};
pub use workflow_output::{
    WORKFLOW_OUTPUT_BEGIN, WORKFLOW_OUTPUT_END, parse_workflow_output,
    with_workflow_output_protocol,
};
pub use workflow_projection::{
    EventWindow, EventWindowOpts, event_seq_from_id, infer_run_status, read_event_window,
    read_run_events_pure,
};
pub use workflow_resume::{
    PriorReconcileRecoveryOutcome, ScheduleResumeOutcome, ScheduleResumeResult,
    recover_prior_reconcile_result, resume_schedule_dangling_effects,
};
pub use workflow_run::{
    BootstrapWorkflowRunInput, RunChatBinding, WorkflowOutputRef, WorkflowRunBootstrap,
    bootstrap_workflow_run, mint_workflow_run_id,
};
pub use workflow_runtime::{
    HostExecutorPrepareResult, RecoveryResult, RunLoopResult, RunLoopStopReason, RunTickResult,
    WorkflowDispatchOutcome, WorkflowDispatchRun, WorkflowDispatchSession, WorkflowExecutionHooks,
    WorkflowRuntimeContext, complete_node_failed, complete_node_succeeded, complete_run_failed,
    complete_run_succeeded, derive_workflow_idempotency_key, dispatch_gate, dispatch_work,
    finish_loop, finish_loop_iteration, get_host_executor_provider_meta, run_loop, run_tick,
    start_loop, start_loop_iteration,
};
pub use workflow_sidecar::{load_effect_input_sidecar, write_effect_input_sidecar};
pub use workflow_snapshot::{
    ActivityState, ActivityStatus, AttemptIODTO, AttemptState, AttemptTerminalDTO, BlobPreviewDTO,
    BotSnapshot, CancelIntent, DanglingSnapshot, EffectAttemptedState, LoopIterationState,
    LoopIterationStatus, LoopSnapshotDTO, LoopState, LoopStatus, NodeState, NodeStatus,
    ReconcileResultState, RunSnapshotDTO, RunState, RunStatus, WaitResolutionState, WaitState,
    read_run_snapshot,
};