first commit

Results.zip

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:210d541415e8f704fa65d9b52b794fc3f130da3bf155ae6ea134826b6ae51d3e
+size 210

app.py

@@ -115,12 +115,8 @@ Please be patient — takes about 20–30 minutes to process.
         """
         import subprocess
         import os
-        import time
-        from datetime import datetime
 
         ui_logs = []  # Simplified logs for UI
-        current_task = 0
-        total_tasks = 4
 
         try:
             # Validate inputs
@@ -132,11 +128,9 @@ Please be patient — takes about 20–30 minutes to process.
                 ui_logs.append("❌ Error: Claude API Key is required")
                 return "\n".join(ui_logs), None, ""
 
-            # Create log file in Results folder
+            # Create Results folder
             results_path = ROOT / "Results"
             results_path.mkdir(parents=True, exist_ok=True)
-            timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
-            log_file_path = results_path / f"log_{timestamp}.log"
 
             ui_logs.append(f"🚀 Starting Paper2Agent pipeline...")
             ui_logs.append(f"📘 GitHub Repo: {github_url}")
@@ -145,7 +139,7 @@ Please be patient — takes about 20–30 minutes to process.
             if tutorials_filter:
                 ui_logs.append(f"📚 Tutorial Filter: {tutorials_filter}")
 
-            ui_logs.append(f"\n📝 Detailed logs: {log_file_path}")
+            ui_logs.append(f"\n📝 Detailed logs will be saved to: Results/log.log")
             ui_logs.append("\n" + "="*70)
             yield "\n".join(ui_logs), None, ""
 
@@ -167,29 +161,23 @@ Please be patient — takes about 20–30 minutes to process.
             if tutorials_filter and tutorials_filter.strip():
                 cmd.extend(["--tutorials", tutorials_filter])
 
-            # Run test.py and write all output to log file
-            with open(log_file_path, 'w', encoding='utf-8') as log_file:
-                process = subprocess.Popen(
-                    cmd,
-                    stdout=subprocess.PIPE,
-                    stderr=subprocess.STDOUT,
-                    text=True,
-                    bufsize=0,
-                    env=env
-                )
-
-                # Stream all output to both log file and UI in real-time
-                for line in iter(process.stdout.readline, ''):
-                    if line:
-                        # Write all output to log file (everything)
-                        log_file.write(line)
-                        log_file.flush()
-
-                        # Add to ui_logs only if not ToolUseBlock
-                        stripped_line = line.strip()
-                        if stripped_line and "ToolUseBlock" not in line and len(stripped_line) < 200:
-                            ui_logs.append(stripped_line)
-                            yield "\n".join(ui_logs), None, ""
+            # Run test.py and capture stdout for UI
+            process = subprocess.Popen(
+                cmd,
+                stdout=subprocess.PIPE,
+                stderr=subprocess.STDOUT,
+                text=True,
+                bufsize=0,
+                env=env
+            )
+
+            # Stream output to UI
+            for line in iter(process.stdout.readline, ''):
+                if line:
+                    stripped_line = line.strip()
+                    if stripped_line:
+                        ui_logs.append(stripped_line)
+                        yield "\n".join(ui_logs), None, ""
 
             process.wait()
 
@@ -207,7 +195,7 @@ Please be patient — takes about 20–30 minutes to process.
                     import shutil
 
                     # Create zip file with timestamp
-                    zip_base_name = f"Results_{timestamp}"
+                    zip_base_name = f"Results"
                     zip_file_path = ROOT / zip_base_name
 
                     try:
@@ -221,7 +209,7 @@ Please be patient — takes about 20–30 minutes to process.
                         zip_file = str(zip_file_path) + ".zip"
                         ui_logs.append(f"✅ Created zip file: {zip_file}")
                         ui_logs.append(f"📥 Ready for download!")
-                        ui_logs.append(f"\n📝 Full logs saved to: {log_file_path}")
+                        ui_logs.append(f"\n📝 Full logs saved to: Results/log.log")
                         yield "\n".join(ui_logs), zip_file, ""
                     except Exception as e:
                         ui_logs.append(f"⚠️ Failed to create zip file: {str(e)}")
@@ -232,14 +220,13 @@ Please be patient — takes about 20–30 minutes to process.
             else:
                 ui_logs.append("\n" + "="*70)
                 ui_logs.append(f"❌ Pipeline failed with exit code {process.returncode}")
-                ui_logs.append(f"📝 Check logs for details: {log_file_path}")
+                ui_logs.append(f"📝 Check logs for details: Results/log.log")
                 ui_logs.append("="*70)
                 yield "\n".join(ui_logs), None, ""
 
         except Exception as e:
             ui_logs.append(f"\n❌ Error: {str(e)}")
-            if 'log_file_path' in locals():
-                ui_logs.append(f"📝 Check logs for details: {log_file_path}")
+            ui_logs.append(f"📝 Check logs for details: Results/log.log")
             yield "\n".join(ui_logs), None, ""
 
     # Connect example button

test.py

@@ -20,7 +20,7 @@ from prompts.tasks import step1_environment_setup_and_tutorial_discovery, step2_
 
 # ANTHROPIC_API_KEY should be set via environment variable by the caller (app.py)
 
-async def fully_automatic(tasks: list, task_descriptions: list = None):
+async def fully_automatic(tasks: list, task_descriptions: list = None, log_file_path: str = None):
     options = ClaudeAgentOptions(
         allowed_tools=["Bash", "Edit", "Glob", "Grep", "NotebookEdit", "NotebookRead", "Read", "SlashCommand", "Task", "TodoWrite", "WebFetch", "WebSearch", "Write"],
         permission_mode='acceptEdits',
@@ -30,37 +30,51 @@ async def fully_automatic(tasks: list, task_descriptions: list = None):
 
     async with ClaudeSDKClient(options=options) as client:
         for i, task in enumerate(tasks, 1):
+            # Simple print for UI
             print(f"\n{'='*70}")
             if task_descriptions and i <= len(task_descriptions):
                 print(f"🚀 Starting {task_descriptions[i-1]}")
             else:
                 print(f"🚀 Starting Task {i}")
             print('='*70 + "\n")
+
             try:
                 await client.query(task)
-
                 async for message in client.receive_response():
-                    
+                    # Write detailed logs to file
+                    if log_file_path:
+                        with open(f"Task_{i}_{log_file_path}", 'a', encoding='utf-8') as log_file:
+                            if isinstance(message, AssistantMessage):
+                                for block in message.content:
+                                    if isinstance(block, TextBlock):
+                                        log_file.write(f"💭 Claude: {block.text}\n")
+                                    elif isinstance(block, ToolUseBlock):
+                                        if hasattr(block, 'input') and block.input:
+                                            if isinstance(block.input, dict):
+                                                for key, value in block.input.items():
+                                                    val_str = str(value)
+                                                    log_file.write(f"[ToolUseBlock] {key}: {val_str}\n")
+                            elif isinstance(message, ToolResultBlock):
+                                if hasattr(message, 'content'):
+                                    result = str(message.content)
+                                    log_file.write(f"  ✅ Result: {result}\n")
+
+                    # Only print brief progress to stdout for UI
                     if isinstance(message, AssistantMessage):
                         for block in message.content:
                             if isinstance(block, TextBlock):
-                                print(f"💭 Claude: {block.text}\n")
-                            elif isinstance(block, ToolUseBlock):
-                                if hasattr(block, 'input') and block.input:
-                                    if isinstance(block.input, dict):
-                                        for key, value in block.input.items():
-                                            val_str = str(value)
-                                            print(f"[ToolUseBlock] {key}: {val_str}\n")
+                                # Only print short text blocks
+                                text = block.text.strip()
+                                if len(text) < 150:
+                                    print(f"💭 {text}")
 
-                    elif isinstance(message, ToolResultBlock):
-                        if hasattr(message, 'content'):
-                            result = str(message.content)
-                            print(f"  ✅ Result: {result}\n")
-
-                print(f"\n  ✅ Task {i} Completed\n")
+                print(f"\n✅ Task {i} Completed\n")
 
             except Exception as e:
-                print(f"  ❌ Task {i} Failed: {e}\n")
+                print(f"❌ Task {i} Failed: {e}\n")
+                if log_file_path:
+                    with open(log_file_path, 'a', encoding='utf-8') as log_file:
+                        log_file.write(f"❌ Task {i} Failed: {e}\n")
 
 
 def main():
@@ -118,8 +132,11 @@ def main():
         print(f"   {i}. {desc}")
     print("="*70 + "\n")
 
+    # Define log file path
+    log_file_path = "log.log"
+
     #print(tasks[0])
-    anyio.run(fully_automatic, tasks, task_descriptions)
+    anyio.run(fully_automatic, tasks, task_descriptions, log_file_path)
 
 
 if __name__ == "__main__":