GameCult/Epiphany
Archived
Watch
9
0
Fork
You've already forked Epiphany
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Delete lenient session ensure writer

Browse source
This commit is contained in:
Meta Vens 2026-08-24 04:09:56 +02:00
commit cd2177e834
4 changed files with 2 additions and 39 deletions
Download patch file Download diff file Expand all files Collapse all files

1
epiphany-core/src/lib.rs
View file

@ -291,7 +291,6 @@ pub use runtime_spine::coordinator_run_receipts;
pub use runtime_spine::coordinator_run_session_id;
pub use runtime_spine::create_runtime_job;
pub use runtime_spine::create_runtime_session;
pub use runtime_spine::ensure_runtime_session;
pub use runtime_spine::finalize_coordinator_run;
pub use runtime_spine::initialize_runtime_spine;
pub use runtime_spine::model_pass_failure_for_request;

36
epiphany-core/src/runtime_spine.rs
View file

@ -1077,42 +1077,6 @@ pub fn create_runtime_session(
Ok(session)
}
pub fn ensure_runtime_session(
store_path: impl AsRef<Path>,
options: RuntimeSpineSessionOptions,
) -> Result<EpiphanyRuntimeSession> {
validate_non_empty(&options.session_id, "session id")?;
validate_non_empty(&options.objective, "objective")?;
validate_non_empty(&options.created_at, "created at")?;
let mut cache = runtime_spine_cache(store_path.as_ref())?;
cache.pull_all_backing_stores()?;
require_identity(&cache)?;
require_runtime_identity_not_archived(&cache, "session", &options.session_id)?;
if let Some(existing) = cache.get::<EpiphanyRuntimeSession>(&options.session_id)? {
if matches!(
existing.status,
EpiphanyRuntimeSessionStatus::Completed | EpiphanyRuntimeSessionStatus::Archived
) {
return Err(anyhow!(
"runtime session {:?} is terminal and cannot accept jobs",
options.session_id
));
}
return Ok(existing);
}
let session = EpiphanyRuntimeSession {
schema_version: RUNTIME_SPINE_SCHEMA_VERSION.to_string(),
session_id: options.session_id.clone(),
objective: options.objective,
status: EpiphanyRuntimeSessionStatus::Active,
created_at: options.created_at.clone(),
updated_at: options.created_at,
coordinator_note: options.coordinator_note,
};
cache.put(&options.session_id, &session)?;
Ok(session)
}
pub fn close_runtime_session(
store_path: impl AsRef<Path>,
options: RuntimeSpineSessionClosureOptions,

2
epiphany-openai-runtime/src/bin/epiphany-openai-runtime.rs
View file

@ -1204,7 +1204,7 @@ mod tests {
created_at: options.created_at.clone(),
},
)?;
epiphany_core::ensure_runtime_session(
epiphany_core::create_runtime_session(
store,
epiphany_core::RuntimeSpineSessionOptions {
session_id: options.session_id.clone(),

2
epiphany-openai-runtime/src/lib.rs
View file

@ -2463,7 +2463,7 @@ mod tests {
created_at: options.created_at.clone(),
},
)?;
epiphany_core::ensure_runtime_session(
epiphany_core::create_runtime_session(
store,
epiphany_core::RuntimeSpineSessionOptions {
session_id: options.session_id.clone(),