Add system

app.py

@@ -175,10 +175,10 @@ def run_model():
             "events": events
         }
         default_log_path = f"{FEEDBACK_DIR}/feedback_{timestamp}_{user_id}.jsonl"
-        step_id = outputs["step_id"]
-        if update_status: 
-            update_status(step_id, "All done!")
-            step_id += 1
+        # step_id = outputs["step_id"]
+        # if update_status: 
+        #     update_status(step_id, "All done!")
+        #     step_id += 1
         with open(default_log_path, "w") as f:
             f.write(json.dumps(log_entry, indent=1))
 

system/pledge_tracking.py

@@ -27,17 +27,9 @@ def count_total_events(output_path):
     with open(output_path, "r", encoding="utf-8") as f:
         results = json.load(f)
 
-    print(results)
     total_events = 0
-    for item in results:
-        try:
-            events = item["output"]
-            if isinstance(events, list):
-                total_events += len(events)
-            else:
-                print(f"invalid: {events}")
-        except KeyError:
-            print(f"lack item: {item}")
+    for result in results:
+        total_events+= len(result["output"]["events"])
 
     print(f"{total_events} events in total")
     return total_events
@@ -187,9 +179,9 @@ def run_pipeline(claim, pledge_date, pledge_author, start_date, timestamp, user_
     df.to_excel(sorted_event_path, index=False)
     print(sorted_event_path)
 
-    # if update_fn: 
-    #     update_fn(step_id, "All done!")
-    #     step_id += 1
+    if update_fn: 
+        update_fn(step_id, "All done!")
+        step_id += 1
 
     return {
         "claim_json": claim_json_path,

test.html

@@ -245,13 +245,20 @@
             const finalText = values.join(" ").toLowerCase();
 
             if (finalText.includes("done") || finalText.includes("finished")) {
-              clearInterval(window.pollIntervalId);
-              window.pollIntervalId = null;
-              statusElement.innerHTML += `<div class="mt-2 text-green-600 font-semibold">✅ All done.</div>`;
-              checkBtn.disabled = false;
-              checkBtn.classList.remove("opacity-50", "cursor-not-allowed");
-              if (lastUsedFile) loadEvents(lastUsedFile);
-            } else if (finalText.includes("error") || finalText.includes("fail")) {
+                clearInterval(window.pollIntervalId);
+                window.pollIntervalId = null;
+                statusElement.innerHTML += `<div class="mt-2 text-green-600 font-semibold">✅ All done.</div>`;
+                checkBtn.disabled = false;
+                checkBtn.classList.remove("opacity-50", "cursor-not-allowed");
+
+                // 🕐 等待 lastUsedFile 准备好
+                const waitForFile = setInterval(() => {
+                  if (lastUsedFile) {
+                    clearInterval(waitForFile);
+                    loadEvents(lastUsedFile);
+                  }
+                }, 200);
+              } else if (finalText.includes("error") || finalText.includes("fail")) {
               clearInterval(window.pollIntervalId);
               window.pollIntervalId = null;
               statusElement.innerHTML += `<div class="mt-2 text-red-600 font-semibold">❌ The process failed.</div>`;