process comment

codex-rs/core/src/memories/phase2.rs

@@ -416,6 +416,26 @@ mod agent {
                 if let Some(token_usage) = agent_control.get_total_token_usage(thread_id).await {
                     emit_token_usage_metrics(&session, &token_usage);
                 }
+                // TODO jif simlpify
+                match db
+                    .heartbeat_global_phase2_job(&claim.token, phase_two::JOB_LEASE_SECONDS)
+                    .await
+                {
+                    Ok(true) => {}
+                    Ok(false) => {
+                        tracing::error!(
+                            "lost global memory consolidation ownership before committing workspace"
+                        );
+                        return;
+                    }
+                    Err(err) => {
+                        tracing::error!(
+                            "failed confirming global memory consolidation ownership before committing workspace: {err}"
+                        );
+                        job::failed(&session, &db, &claim, "failed_confirm_ownership").await;
+                        return;
+                    }
+                }
                 if let Err(err) = commit_all(&memory_root).await {
                     tracing::error!("failed committing memory workspace: {err}");
                     job::failed(&session, &db, &claim, "failed_workspace_commit").await;