mirror of
https://github.com/pchuan98/codex.git
synced 2026-07-01 00:31:56 +08:00
committed by
GitHub
Unverified
parent
93456320ef
commit
66d5edf825
@@ -161,7 +161,7 @@ impl ThreadGoalRequestProcessor {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
codex_state::ThreadGoalUpdate {
|
||||
codex_state::GoalUpdate {
|
||||
objective: Some(objective.to_string()),
|
||||
status,
|
||||
token_budget: params.token_budget,
|
||||
@@ -206,7 +206,7 @@ impl ThreadGoalRequestProcessor {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
codex_state::ThreadGoalUpdate {
|
||||
codex_state::GoalUpdate {
|
||||
objective: None,
|
||||
status,
|
||||
token_budget: params.token_budget,
|
||||
|
||||
@@ -476,7 +476,7 @@ impl Session {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
self.conversation_id,
|
||||
codex_state::ThreadGoalUpdate {
|
||||
codex_state::GoalUpdate {
|
||||
objective: Some(objective.to_string()),
|
||||
status: status.map(state_goal_status_from_protocol),
|
||||
token_budget,
|
||||
@@ -516,7 +516,7 @@ impl Session {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
self.conversation_id,
|
||||
codex_state::ThreadGoalUpdate {
|
||||
codex_state::GoalUpdate {
|
||||
objective: None,
|
||||
status,
|
||||
token_budget,
|
||||
|
||||
@@ -8620,7 +8620,7 @@ async fn external_goal_mutation_accounts_active_turn_before_status_change() -> a
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
sess.conversation_id,
|
||||
codex_state::ThreadGoalUpdate {
|
||||
codex_state::GoalUpdate {
|
||||
objective: None,
|
||||
status: Some(codex_state::ThreadGoalStatus::Complete),
|
||||
token_budget: None,
|
||||
|
||||
@@ -50,11 +50,11 @@ pub use model::ThreadMetadataBuilder;
|
||||
pub use model::ThreadsPage;
|
||||
pub use runtime::GoalAccountingMode;
|
||||
pub use runtime::GoalStore;
|
||||
pub use runtime::GoalUpdate;
|
||||
pub use runtime::RemoteControlEnrollmentRecord;
|
||||
pub use runtime::RuntimeDbPath;
|
||||
pub use runtime::ThreadFilterOptions;
|
||||
pub use runtime::ThreadGoalAccountingOutcome;
|
||||
pub use runtime::ThreadGoalUpdate;
|
||||
pub use runtime::goals_db_filename;
|
||||
pub use runtime::goals_db_path;
|
||||
pub use runtime::logs_db_filename;
|
||||
|
||||
@@ -68,8 +68,9 @@ mod threads;
|
||||
|
||||
pub use goals::GoalAccountingMode;
|
||||
pub use goals::GoalStore;
|
||||
pub use goals::GoalUpdate;
|
||||
pub use goals::ThreadGoalAccountingMode;
|
||||
pub use goals::ThreadGoalAccountingOutcome;
|
||||
pub use goals::ThreadGoalUpdate;
|
||||
pub use remote_control::RemoteControlEnrollmentRecord;
|
||||
pub use threads::ThreadFilterOptions;
|
||||
|
||||
|
||||
@@ -13,7 +13,7 @@ impl GoalStore {
|
||||
}
|
||||
}
|
||||
|
||||
pub struct ThreadGoalUpdate {
|
||||
pub struct GoalUpdate {
|
||||
pub objective: Option<String>,
|
||||
pub status: Option<crate::ThreadGoalStatus>,
|
||||
pub token_budget: Option<Option<i64>>,
|
||||
@@ -170,9 +170,9 @@ RETURNING
|
||||
pub async fn update_thread_goal(
|
||||
&self,
|
||||
thread_id: ThreadId,
|
||||
update: ThreadGoalUpdate,
|
||||
update: GoalUpdate,
|
||||
) -> anyhow::Result<Option<crate::ThreadGoal>> {
|
||||
let ThreadGoalUpdate {
|
||||
let GoalUpdate {
|
||||
objective,
|
||||
status,
|
||||
token_budget,
|
||||
@@ -556,7 +556,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: None,
|
||||
status: Some(crate::ThreadGoalStatus::Paused),
|
||||
token_budget: Some(Some(200_000)),
|
||||
@@ -732,7 +732,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: None,
|
||||
status: Some(crate::ThreadGoalStatus::Complete),
|
||||
token_budget: None,
|
||||
@@ -756,7 +756,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: None,
|
||||
status: Some(crate::ThreadGoalStatus::Complete),
|
||||
token_budget: None,
|
||||
@@ -853,7 +853,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: Some("draft the report clearly".to_string()),
|
||||
status: Some(crate::ThreadGoalStatus::Paused),
|
||||
token_budget: Some(Some(200)),
|
||||
@@ -891,7 +891,7 @@ mod tests {
|
||||
|
||||
let status_update = runtime.thread_goals().update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: None,
|
||||
status: Some(crate::ThreadGoalStatus::Paused),
|
||||
token_budget: None,
|
||||
@@ -900,7 +900,7 @@ mod tests {
|
||||
);
|
||||
let budget_update = runtime.thread_goals().update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: None,
|
||||
status: None,
|
||||
token_budget: Some(Some(200_000)),
|
||||
@@ -954,7 +954,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: None,
|
||||
status: Some(crate::ThreadGoalStatus::Complete),
|
||||
token_budget: None,
|
||||
@@ -1165,7 +1165,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
crate::ThreadGoalUpdate {
|
||||
crate::GoalUpdate {
|
||||
objective: None,
|
||||
status: Some(crate::ThreadGoalStatus::Paused),
|
||||
token_budget: None,
|
||||
@@ -1225,7 +1225,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: None,
|
||||
status: None,
|
||||
token_budget: Some(Some(40)),
|
||||
@@ -1272,7 +1272,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: Some("stay within budget, with clearer wording".to_string()),
|
||||
status: Some(crate::ThreadGoalStatus::Active),
|
||||
token_budget: None,
|
||||
@@ -1323,7 +1323,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: None,
|
||||
status: Some(crate::ThreadGoalStatus::Paused),
|
||||
token_budget: None,
|
||||
@@ -1373,7 +1373,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: None,
|
||||
status: Some(crate::ThreadGoalStatus::Blocked),
|
||||
token_budget: None,
|
||||
@@ -1463,7 +1463,7 @@ mod tests {
|
||||
.thread_goals()
|
||||
.update_thread_goal(
|
||||
thread_id,
|
||||
ThreadGoalUpdate {
|
||||
GoalUpdate {
|
||||
objective: None,
|
||||
status: Some(crate::ThreadGoalStatus::Paused),
|
||||
token_budget: None,
|
||||
|
||||
Reference in New Issue
Block a user