fmt: phase_summarizer
This commit is contained in:
@@ -82,9 +82,7 @@ async fn summarize_one(
|
|||||||
kind: &str,
|
kind: &str,
|
||||||
) -> Result<(), String> {
|
) -> Result<(), String> {
|
||||||
let material = collect_material(pool, mission_id, phase_id).await?;
|
let material = collect_material(pool, mission_id, phase_id).await?;
|
||||||
if material.outputs.is_empty()
|
if material.outputs.is_empty() && material.tasks_created == 0 && material.artifacts.is_empty()
|
||||||
&& material.tasks_created == 0
|
|
||||||
&& material.artifacts.is_empty()
|
|
||||||
{
|
{
|
||||||
// Nothing to summarize. Write a placeholder so we don't retry
|
// Nothing to summarize. Write a placeholder so we don't retry
|
||||||
// this phase every 30s.
|
// this phase every 30s.
|
||||||
@@ -286,10 +284,7 @@ async fn collect_material(
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn call_anthropic(
|
async fn call_anthropic(kind: &str, material: &PhaseMaterial) -> Result<(String, Value), String> {
|
||||||
kind: &str,
|
|
||||||
material: &PhaseMaterial,
|
|
||||||
) -> Result<(String, Value), String> {
|
|
||||||
let api_key =
|
let api_key =
|
||||||
std::env::var("ANTHROPIC_API_KEY").map_err(|_| "ANTHROPIC_API_KEY unset".to_string())?;
|
std::env::var("ANTHROPIC_API_KEY").map_err(|_| "ANTHROPIC_API_KEY unset".to_string())?;
|
||||||
let model = model_name();
|
let model = model_name();
|
||||||
|
|||||||
Reference in New Issue
Block a user