adding download file of the question

agents.py

@@ -4,10 +4,10 @@ from smolagents import (
     ToolCallingAgent,
     CodeAgent,
     VisitWebpageTool,
-    DuckDuckGoSearchTool,
     WebSearchTool,
 )
 import os
+from typing import Optional
 
 
 gemini_api_key = os.environ.get("GEMINI_API_KEY", None)
@@ -43,8 +43,14 @@ class SkynetMultiAgent:
             additional_authorized_imports=["time", "numpy", "pandas"],
         )
 
-    def __call__(self, question: str) -> str:
+    def __call__(self, question: str, file_path: Optional[str] = None) -> str:
         print(f"Agent received question (first 50 chars): {question[:50]}...")
-        fixed_answer = self.agent.run(question, max_steps=10)
+        # Adding extra content if provided
+        if file_path and os.path.exists(file_path):
+            eval_question = f"{question}\n\nFile provided: {file_path}"
+            print(f"Processing question with file: {file_path}")
+        else:
+            eval_question = question
+        fixed_answer = self.agent.run(eval_question, max_steps=10)
         print(f"Agent returning fixed answer: {fixed_answer}")
         return fixed_answer

app.py

@@ -3,6 +3,7 @@ import gradio as gr
 import requests
 import pandas as pd
 from agents import SkynetMultiAgent
+from utils import download_file, clean_answer_for_eval
 
 # (Keep Constants as is)
 # --- Constants ---
@@ -27,7 +28,7 @@ def run_and_submit_all(profile: gr.OAuthProfile | None):
     api_url = DEFAULT_API_URL
     questions_url = f"{api_url}/questions"
     submit_url = f"{api_url}/submit"
-    
+
     # 1. Instantiate Agent ( modify this part to create your agent)
     try:
         agent = SkynetMultiAgent()
@@ -43,7 +44,7 @@ def run_and_submit_all(profile: gr.OAuthProfile | None):
     print(f"Fetching questions from: {questions_url}")
     try:
         response = requests.get(
-            questions_url, timeout=30
+            questions_url, timeout=60
         )  # increasing timeout because gemini model.
         response.raise_for_status()
         questions_data = response.json()
@@ -65,34 +66,32 @@ def run_and_submit_all(profile: gr.OAuthProfile | None):
     # 3. Run your Agent
     results_log = []
     answers_payload = []
+    downloaded_files = []
     print(f"Running agent on {len(questions_data)} questions...")
     for item in questions_data:
         task_id = item.get("task_id")
-        # try to download the file if available
-        files_url = f"{api_url}/files/{task_id}"
-        try:
-            file_response = requests.get(files_url, timeout=10)
-            if file_response.status_code == 200:
-                item["file_content"] = file_response.text
-                print(f"File for task {task_id} fetched successfully.")
-            else:
-                print(f"No file found for task {task_id}. Status code: {file_response.status_code}")
-        except requests.exceptions.RequestException as e:
-            print(f"Error fetching file for task {task_id}: {e}")
         question_text = item.get("question")
+        file_name = item.get("file_name")
         if not task_id or question_text is None:
             print(f"Skipping item with missing task_id or question: {item}")
             continue
+        downloaded_file_path = None
+        if file_name:
+            print(f"Task {task_id} has file: {file_name}")
+            downloaded_file_path = download_file(task_id, api_url)
+            if downloaded_file_path:
+                downloaded_files.append(downloaded_file_path)
         try:
-            submitted_answer = agent(question_text)
+            submitted_answer = agent(question_text, downloaded_file_path)
+            cleaned_answer = clean_answer_for_eval(submitted_answer)
             answers_payload.append(
-                {"task_id": task_id, "submitted_answer": submitted_answer}
+                {"task_id": task_id, "submitted_answer": cleaned_answer}
             )
             results_log.append(
                 {
                     "Task ID": task_id,
                     "Question": question_text,
-                    "Submitted Answer": submitted_answer,
+                    "Submitted Answer": cleaned_answer,
                 }
             )
         except Exception as e:
@@ -104,6 +103,14 @@ def run_and_submit_all(profile: gr.OAuthProfile | None):
                     "Submitted Answer": f"AGENT ERROR: {e}",
                 }
             )
+    # cleanup downloaded files
+    for file_path in downloaded_files:
+        try:
+            if os.path.exists(file_path):
+                os.remove(file_path)
+                print(f"Removed file: {file_path}")
+        except Exception as e:
+            print(f"Could not remove {file_path}: {e}")
 
     if not answers_payload:
         print("Agent did not produce any answers to submit.")
@@ -169,9 +176,9 @@ with gr.Blocks() as demo:
         """
         **Instructions:**
 
-        1.  Please clone this space, then modify the code to define your agent's logic, the tools, the necessary packages, etc ...
-        2.  Log in to your Hugging Face account using the button below. This uses your HF username for submission.
-        3.  Click 'Run Evaluation & Submit All Answers' to fetch questions, run your agent, submit answers, and see the score.
+
+        1.  Log in to your Hugging Face account using the button below. This uses your HF username for submission.
+        2.  Click 'Run Evaluation & Submit All Answers' to fetch questions, run your agent, submit answers, and see the score.
 
         ---
         **Disclaimers:**

tools.py

@@ -0,0 +1,63 @@
+
+
+from smolagents import Tool
+from langchain_community.retrievers import BM25Retriever
+from langchain.docstore.document import Document
+
+# Create a tool to download a file
+# The point is: in the basic HF template, you just pass the question to the model, 
+# instead you should provide also the file name when available and then allow the model to 
+# automatically download the file from the /files/{task_id} api
+# doc https://agents-course-unit4-scoring.hf.space/docs
+
+class DownloadFilesTool(Tool):
+    name = "topic_info_retriever"
+    description = "Retrieves detailed information about a specific topic from a set of documents."
+    inputs = {
+        "query": {
+            "type": "string",
+            "description": "The topic you want information about.",
+        }
+    }
+    output_type = "string"
+
+    def __init__(self, docs):
+        self.is_initialized = False
+        self.retriever = BM25Retriever.from_documents(docs)
+
+    def forward(self, query: str):
+        results = self.retriever.get_relevant_documents(query)
+        if results:
+            return "\n\n".join([doc.page_content for doc in results[:3]])
+        else:
+            return "No matching guest information found."
+        
+class PythonCodeAnalyzerTool(Tool):
+    name = "python_code_analyzer"
+    description = "Analyzes Python code to identify potential issues. If requested it may execute the code."
+    inputs = {
+        "file_path": {
+            "type": "string",
+            "description": "The Python code file to analyze.",
+        },
+        "question": {
+            "type": "string",
+            "description": "A question or request for analysis of the code.",
+        }
+    }
+    output_type = "string"
+    def __init__(self, file_path: str, question: str):
+        try:
+            # Read the Python file
+            with open(file_path, 'r', encoding='utf-8') as f:
+                self.code_content = f.read()
+        except Exception as e:
+            error_msg = f"Error analyzing Python file: {str(e)}"
+            raise ValueError(error_msg)
+        self.question = question
+        self.is_initialized = True
+
+    def forward(self, code: str):
+        # Placeholder for actual code analysis logic
+        # In a real implementation, you would use a library or service to analyze the code
+        return f"Analyzed code:\n{code}\n\nNo issues found."

utils.py

@@ -0,0 +1,64 @@
+import os
+import requests
+from typing import Optional
+import tempfile
+
+# --- File Download Helper Function ---
+def download_file(task_id: str, api_url: str) -> Optional[str]:
+    """Download file associated with a task_id from the evaluation API"""
+    try:
+        file_url = f"{api_url}/files/{task_id}"
+        print(f"📁 Downloading file for task {task_id}")
+        
+        response = requests.get(file_url, timeout=30)
+        response.raise_for_status()
+        
+        # Get filename from headers or create one
+        content_disposition = response.headers.get('Content-Disposition', '')
+        if 'filename=' in content_disposition:
+            filename = content_disposition.split('filename=')[1].strip('"')
+        else:
+            content_type = response.headers.get('Content-Type', '')
+            if 'image' in content_type:
+                extension = '.jpg'
+            elif 'audio' in content_type:
+                extension = '.mp3'
+            elif 'video' in content_type:
+                extension = '.mp4'
+            else:
+                extension = '.txt'
+            filename = f"task_{task_id}_file{extension}"
+        
+        # Save to temporary file
+        temp_dir = tempfile.gettempdir()
+        file_path = os.path.join(temp_dir, filename)
+        
+        with open(file_path, 'wb') as f:
+            f.write(response.content)
+        
+        print(f"✅ File downloaded: {file_path}")
+        return file_path
+        
+    except Exception as e:
+        print(f"❌ Error downloading file for task {task_id}: {e}")
+        return None
+    
+def clean_answer_for_eval(answer: str) -> str:
+    """Clean the answer string for evaluation purposes."""
+    #
+    if isinstance(answer, str):
+        answer = answer.strip()
+        
+        prefixes_to_remove = [
+            "The answer is: ",
+            "Answer: ",
+            "The result is: ",
+            "Result: ",
+            "The final answer is: ",
+        ]
+        
+        for prefix in prefixes_to_remove:
+            if answer.startswith(prefix):
+                answer = answer[len(prefix):].strip()
+                break
+    return answer