shabanramadani commited on
Commit
1c9508d
·
0 Parent(s):

import from basic template

Browse files
Files changed (7) hide show
  1. .gitattributes +35 -0
  2. .gitignore +4 -0
  3. README.md +15 -0
  4. agent.py +22 -0
  5. app.py +195 -0
  6. requirements.txt +9 -0
  7. tools.py +91 -0
.gitattributes ADDED
@@ -0,0 +1,35 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ *.7z filter=lfs diff=lfs merge=lfs -text
2
+ *.arrow filter=lfs diff=lfs merge=lfs -text
3
+ *.bin filter=lfs diff=lfs merge=lfs -text
4
+ *.bz2 filter=lfs diff=lfs merge=lfs -text
5
+ *.ckpt filter=lfs diff=lfs merge=lfs -text
6
+ *.ftz filter=lfs diff=lfs merge=lfs -text
7
+ *.gz filter=lfs diff=lfs merge=lfs -text
8
+ *.h5 filter=lfs diff=lfs merge=lfs -text
9
+ *.joblib filter=lfs diff=lfs merge=lfs -text
10
+ *.lfs.* filter=lfs diff=lfs merge=lfs -text
11
+ *.mlmodel filter=lfs diff=lfs merge=lfs -text
12
+ *.model filter=lfs diff=lfs merge=lfs -text
13
+ *.msgpack filter=lfs diff=lfs merge=lfs -text
14
+ *.npy filter=lfs diff=lfs merge=lfs -text
15
+ *.npz filter=lfs diff=lfs merge=lfs -text
16
+ *.onnx filter=lfs diff=lfs merge=lfs -text
17
+ *.ot filter=lfs diff=lfs merge=lfs -text
18
+ *.parquet filter=lfs diff=lfs merge=lfs -text
19
+ *.pb filter=lfs diff=lfs merge=lfs -text
20
+ *.pickle filter=lfs diff=lfs merge=lfs -text
21
+ *.pkl filter=lfs diff=lfs merge=lfs -text
22
+ *.pt filter=lfs diff=lfs merge=lfs -text
23
+ *.pth filter=lfs diff=lfs merge=lfs -text
24
+ *.rar filter=lfs diff=lfs merge=lfs -text
25
+ *.safetensors filter=lfs diff=lfs merge=lfs -text
26
+ saved_model/**/* filter=lfs diff=lfs merge=lfs -text
27
+ *.tar.* filter=lfs diff=lfs merge=lfs -text
28
+ *.tar filter=lfs diff=lfs merge=lfs -text
29
+ *.tflite filter=lfs diff=lfs merge=lfs -text
30
+ *.tgz filter=lfs diff=lfs merge=lfs -text
31
+ *.wasm filter=lfs diff=lfs merge=lfs -text
32
+ *.xz filter=lfs diff=lfs merge=lfs -text
33
+ *.zip filter=lfs diff=lfs merge=lfs -text
34
+ *.zst filter=lfs diff=lfs merge=lfs -text
35
+ *tfevents* filter=lfs diff=lfs merge=lfs -text
.gitignore ADDED
@@ -0,0 +1,4 @@
 
 
 
 
 
1
+ .idea
2
+ env
3
+ __pycache__
4
+ .env
README.md ADDED
@@ -0,0 +1,15 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ ---
2
+ title: Template Final Assignment
3
+ emoji: 🕵🏻‍♂️
4
+ colorFrom: indigo
5
+ colorTo: indigo
6
+ sdk: gradio
7
+ sdk_version: 5.25.2
8
+ app_file: app.py
9
+ pinned: false
10
+ hf_oauth: true
11
+ # optional, default duration is 8 hours/480 minutes. Max duration is 30 days/43200 minutes.
12
+ hf_oauth_expiration_minutes: 480
13
+ ---
14
+
15
+ Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
agent.py ADDED
@@ -0,0 +1,22 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ from smolagents import InferenceClientModel, CodeAgent, WebSearchTool
2
+
3
+ from tools import multiply, add, subtract, divide, modulus, wiki_search, arvix_search
4
+
5
+ model = InferenceClientModel(provider="together", model_id="Qwen/Qwen3-235B-A22B-FP8")
6
+
7
+ agent = CodeAgent(
8
+ model=model,
9
+ tools=[multiply, add, subtract, divide, modulus, wiki_search, arvix_search, WebSearchTool()],
10
+ additional_authorized_imports=["time", "numpy", "pandas"],
11
+ max_steps=20,
12
+ )
13
+
14
+
15
+ def get_agent_response(question: str) -> str:
16
+ """Get the agent's response to a question."""
17
+ try:
18
+ response = agent.run(question)
19
+ return response
20
+ except Exception as e:
21
+ print(f"Error during agent invocation: {e}")
22
+ return "Error during agent invocation"
app.py ADDED
@@ -0,0 +1,195 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import os
2
+ import gradio as gr
3
+ import requests
4
+ import pandas as pd
5
+
6
+ from dotenv import load_dotenv
7
+ from agent import get_agent_response
8
+
9
+ load_dotenv()
10
+
11
+ # (Keep Constants as is)
12
+ # --- Constants ---
13
+ DEFAULT_API_URL = "https://agents-course-unit4-scoring.hf.space"
14
+
15
+ # --- Basic Agent Definition ---
16
+ # ----- THIS IS WERE YOU CAN BUILD WHAT YOU WANT ------
17
+ class BasicAgent:
18
+ def __init__(self):
19
+ print("BasicAgent initialized.")
20
+ def __call__(self, question: str) -> str:
21
+ return get_agent_response(question)
22
+
23
+ def run_and_submit_all( profile: gr.OAuthProfile | None):
24
+ """
25
+ Fetches all questions, runs the BasicAgent on them, submits all answers,
26
+ and displays the results.
27
+ """
28
+ # --- Determine HF Space Runtime URL and Repo URL ---
29
+ space_id = os.getenv("SPACE_ID") # Get the SPACE_ID for sending link to the code
30
+
31
+ if profile:
32
+ username= f"{profile.username}"
33
+ print(f"User logged in: {username}")
34
+ else:
35
+ print("User not logged in.")
36
+ return "Please Login to Hugging Face with the button.", None
37
+
38
+ api_url = DEFAULT_API_URL
39
+ questions_url = f"{api_url}/questions"
40
+ submit_url = f"{api_url}/submit"
41
+
42
+ # 1. Instantiate Agent ( modify this part to create your agent)
43
+ try:
44
+ agent = BasicAgent()
45
+ except Exception as e:
46
+ print(f"Error instantiating agent: {e}")
47
+ return f"Error initializing agent: {e}", None
48
+ # In the case of an app running as a hugging Face space, this link points toward your codebase ( usefull for others so please keep it public)
49
+ agent_code = f"https://huggingface.co/spaces/{space_id}/tree/main"
50
+ print(agent_code)
51
+
52
+ # 2. Fetch Questions
53
+ print(f"Fetching questions from: {questions_url}")
54
+ try:
55
+ response = requests.get(questions_url, timeout=15)
56
+ response.raise_for_status()
57
+ questions_data = response.json()
58
+ if not questions_data:
59
+ print("Fetched questions list is empty.")
60
+ return "Fetched questions list is empty or invalid format.", None
61
+ print(f"Fetched {len(questions_data)} questions.")
62
+ except requests.exceptions.RequestException as e:
63
+ print(f"Error fetching questions: {e}")
64
+ return f"Error fetching questions: {e}", None
65
+ except requests.exceptions.JSONDecodeError as e:
66
+ print(f"Error decoding JSON response from questions endpoint: {e}")
67
+ print(f"Response text: {response.text[:500]}")
68
+ return f"Error decoding server response for questions: {e}", None
69
+ except Exception as e:
70
+ print(f"An unexpected error occurred fetching questions: {e}")
71
+ return f"An unexpected error occurred fetching questions: {e}", None
72
+
73
+ # 3. Run your Agent
74
+ results_log = []
75
+ answers_payload = []
76
+ print(f"Running agent on {len(questions_data)} questions...")
77
+ for item in questions_data:
78
+ task_id = item.get("task_id")
79
+ question_text = item.get("question")
80
+ if not task_id or question_text is None:
81
+ print(f"Skipping item with missing task_id or question: {item}")
82
+ continue
83
+ try:
84
+ submitted_answer = agent(question_text)
85
+ answers_payload.append({"task_id": task_id, "submitted_answer": submitted_answer})
86
+ results_log.append({"Task ID": task_id, "Question": question_text, "Submitted Answer": submitted_answer})
87
+ except Exception as e:
88
+ print(f"Error running agent on task {task_id}: {e}")
89
+ results_log.append({"Task ID": task_id, "Question": question_text, "Submitted Answer": f"AGENT ERROR: {e}"})
90
+
91
+ if not answers_payload:
92
+ print("Agent did not produce any answers to submit.")
93
+ return "Agent did not produce any answers to submit.", pd.DataFrame(results_log)
94
+
95
+ # 4. Prepare Submission
96
+ submission_data = {"username": username.strip(), "agent_code": agent_code, "answers": answers_payload}
97
+ status_update = f"Agent finished. Submitting {len(answers_payload)} answers for user '{username}'..."
98
+ print(status_update)
99
+
100
+ # 5. Submit
101
+ print(f"Submitting {len(answers_payload)} answers to: {submit_url}")
102
+ try:
103
+ response = requests.post(submit_url, json=submission_data, timeout=60)
104
+ response.raise_for_status()
105
+ result_data = response.json()
106
+ final_status = (
107
+ f"Submission Successful!\n"
108
+ f"User: {result_data.get('username')}\n"
109
+ f"Overall Score: {result_data.get('score', 'N/A')}% "
110
+ f"({result_data.get('correct_count', '?')}/{result_data.get('total_attempted', '?')} correct)\n"
111
+ f"Message: {result_data.get('message', 'No message received.')}"
112
+ )
113
+ print("Submission successful.")
114
+ results_df = pd.DataFrame(results_log)
115
+ return final_status, results_df
116
+ except requests.exceptions.HTTPError as e:
117
+ error_detail = f"Server responded with status {e.response.status_code}."
118
+ try:
119
+ error_json = e.response.json()
120
+ error_detail += f" Detail: {error_json.get('detail', e.response.text)}"
121
+ except requests.exceptions.JSONDecodeError:
122
+ error_detail += f" Response: {e.response.text[:500]}"
123
+ status_message = f"Submission Failed: {error_detail}"
124
+ print(status_message)
125
+ results_df = pd.DataFrame(results_log)
126
+ return status_message, results_df
127
+ except requests.exceptions.Timeout:
128
+ status_message = "Submission Failed: The request timed out."
129
+ print(status_message)
130
+ results_df = pd.DataFrame(results_log)
131
+ return status_message, results_df
132
+ except requests.exceptions.RequestException as e:
133
+ status_message = f"Submission Failed: Network error - {e}"
134
+ print(status_message)
135
+ results_df = pd.DataFrame(results_log)
136
+ return status_message, results_df
137
+ except Exception as e:
138
+ status_message = f"An unexpected error occurred during submission: {e}"
139
+ print(status_message)
140
+ results_df = pd.DataFrame(results_log)
141
+ return status_message, results_df
142
+
143
+
144
+ # --- Build Gradio Interface using Blocks ---
145
+ with gr.Blocks() as demo:
146
+ gr.Markdown("# Basic Agent Evaluation Runner")
147
+ gr.Markdown(
148
+ """
149
+ **Instructions:**
150
+ 1. Please clone this space, then modify the code to define your agent's logic, the tools, the necessary packages, etc ...
151
+ 2. Log in to your Hugging Face account using the button below. This uses your HF username for submission.
152
+ 3. Click 'Run Evaluation & Submit All Answers' to fetch questions, run your agent, submit answers, and see the score.
153
+ ---
154
+ **Disclaimers:**
155
+ Once clicking on the "submit button, it can take quite some time ( this is the time for the agent to go through all the questions).
156
+ This space provides a basic setup and is intentionally sub-optimal to encourage you to develop your own, more robust solution. For instance for the delay process of the submit button, a solution could be to cache the answers and submit in a seperate action or even to answer the questions in async.
157
+ """
158
+ )
159
+
160
+ gr.LoginButton()
161
+
162
+ run_button = gr.Button("Run Evaluation & Submit All Answers")
163
+
164
+ status_output = gr.Textbox(label="Run Status / Submission Result", lines=5, interactive=False)
165
+ # Removed max_rows=10 from DataFrame constructor
166
+ results_table = gr.DataFrame(label="Questions and Agent Answers", wrap=True)
167
+
168
+ run_button.click(
169
+ fn=run_and_submit_all,
170
+ outputs=[status_output, results_table]
171
+ )
172
+
173
+ if __name__ == "__main__":
174
+ print("\n" + "-"*30 + " App Starting " + "-"*30)
175
+ # Check for SPACE_HOST and SPACE_ID at startup for information
176
+ space_host_startup = os.getenv("SPACE_HOST")
177
+ space_id_startup = os.getenv("SPACE_ID") # Get SPACE_ID at startup
178
+
179
+ if space_host_startup:
180
+ print(f"✅ SPACE_HOST found: {space_host_startup}")
181
+ print(f" Runtime URL should be: https://{space_host_startup}.hf.space")
182
+ else:
183
+ print("ℹ️ SPACE_HOST environment variable not found (running locally?).")
184
+
185
+ if space_id_startup: # Print repo URLs if SPACE_ID is found
186
+ print(f"✅ SPACE_ID found: {space_id_startup}")
187
+ print(f" Repo URL: https://huggingface.co/spaces/{space_id_startup}")
188
+ print(f" Repo Tree URL: https://huggingface.co/spaces/{space_id_startup}/tree/main")
189
+ else:
190
+ print("ℹ️ SPACE_ID environment variable not found (running locally?). Repo URL cannot be determined.")
191
+
192
+ print("-"*(60 + len(" App Starting ")) + "\n")
193
+
194
+ print("Launching Gradio Interface for Basic Agent Evaluation...")
195
+ demo.launch(debug=True, share=False)
requirements.txt ADDED
@@ -0,0 +1,9 @@
 
 
 
 
 
 
 
 
 
 
1
+ gradio
2
+ requests
3
+ huggingface_hub
4
+ itsdangerous
5
+ dotenv
6
+ smolagents
7
+ langchain-community
8
+ wikipedia
9
+ arxiv
tools.py ADDED
@@ -0,0 +1,91 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ from langchain_community.document_loaders import ArxivLoader
2
+ from langchain_community.document_loaders import ArxivLoader
3
+ from langchain_community.document_loaders import WikipediaLoader
4
+ from smolagents import tool, CodeAgent
5
+
6
+
7
+ @tool
8
+ def multiply(a: int, b: int) -> int:
9
+ """Multiply two numbers.
10
+
11
+ Args:
12
+ a: first int
13
+ b: second int
14
+ """
15
+ return a * b
16
+
17
+
18
+ @tool
19
+ def add(a: int, b: int) -> int:
20
+ """Add two numbers.
21
+
22
+ Args:
23
+ a: first int
24
+ b: second int
25
+ """
26
+ return a + b
27
+
28
+
29
+ @tool
30
+ def subtract(a: int, b: int) -> int:
31
+ """Subtract two numbers.
32
+
33
+ Args:
34
+ a: first int
35
+ b: second int
36
+ """
37
+ return a - b
38
+
39
+
40
+ @tool
41
+ def divide(a: int, b: int) -> int:
42
+ """Divide two numbers.
43
+
44
+ Args:
45
+ a: first int
46
+ b: second int
47
+ """
48
+ if b == 0:
49
+ raise ValueError("Cannot divide by zero.")
50
+ return a / b
51
+
52
+
53
+ @tool
54
+ def modulus(a: int, b: int) -> int:
55
+ """Get the modulus of two numbers.
56
+
57
+ Args:
58
+ a: first int
59
+ b: second int
60
+ """
61
+ return a % b
62
+
63
+
64
+ @tool
65
+ def wiki_search(query: str) -> str:
66
+ """Search Wikipedia for a query and return maximum 2 results.
67
+
68
+ Args:
69
+ query: The search query."""
70
+ search_docs = WikipediaLoader(query=query, load_max_docs=2).load()
71
+ formatted_search_docs = "\n\n---\n\n".join(
72
+ [
73
+ f'<Document source="{doc.metadata["source"]}" page="{doc.metadata.get("page", "")}"/>\n{doc.page_content}\n</Document>'
74
+ for doc in search_docs
75
+ ])
76
+ return {"wiki_results": formatted_search_docs}
77
+
78
+
79
+ @tool
80
+ def arvix_search(query: str) -> str:
81
+ """Search Arxiv for a query and return maximum 3 result.
82
+
83
+ Args:
84
+ query: The search query."""
85
+ search_docs = ArxivLoader(query=query, load_max_docs=3).load()
86
+ formatted_search_docs = "\n\n---\n\n".join(
87
+ [
88
+ f'<Document source="{doc.metadata["source"]}" page="{doc.metadata.get("page", "")}"/>\n{doc.page_content[:1000]}\n</Document>'
89
+ for doc in search_docs
90
+ ])
91
+ return {"arvix_results": formatted_search_docs}