Delete agent.py
Browse files
agent.py
DELETED
@@ -1,137 +0,0 @@
|
|
1 |
-
# agent.py
|
2 |
-
|
3 |
-
import os
|
4 |
-
import requests
|
5 |
-
from smolagents import LiteLLMModel, CodeAgent, tool, DuckDuckGoSearchTool, SpeechToTextTool, VisitWebpageTool
|
6 |
-
import speech_recognition as sr
|
7 |
-
from pydub import AudioSegment
|
8 |
-
from PIL import Image
|
9 |
-
|
10 |
-
# Ustaw endpoint API (dostosuj jeśli inny)
|
11 |
-
api_url = "https://agents-course-unit4-scoring.hf.space"
|
12 |
-
|
13 |
-
# ==== Narzędzia własne do podpięcia ====
|
14 |
-
|
15 |
-
@tool
|
16 |
-
def download_question_file(task_id: str, file_name: str = "", save_dir: str = ".") -> str:
|
17 |
-
"""
|
18 |
-
Downloads the file associated with a given task ID and saves it to disk.
|
19 |
-
Args:
|
20 |
-
task_id (str): Unique question/task identifier.
|
21 |
-
file_name (str): Optional file name.
|
22 |
-
save_dir (str): Directory to save.
|
23 |
-
Returns:
|
24 |
-
str: Path to the saved file, or error.
|
25 |
-
"""
|
26 |
-
url = f"{api_url}/files/{task_id}"
|
27 |
-
try:
|
28 |
-
resp = requests.get(url, timeout=15)
|
29 |
-
resp.raise_for_status()
|
30 |
-
except requests.exceptions.HTTPError as e:
|
31 |
-
return f"HTTP error: {e.response.status_code}"
|
32 |
-
except Exception as e:
|
33 |
-
return f"Network error: {e}"
|
34 |
-
content_disposition = resp.headers.get("Content-Disposition", "")
|
35 |
-
filename = (
|
36 |
-
content_disposition.split('filename="')[-1].rstrip('"')
|
37 |
-
if "filename=" in content_disposition
|
38 |
-
else file_name if file_name else f"{task_id}.dat"
|
39 |
-
)
|
40 |
-
os.makedirs(save_dir, exist_ok=True)
|
41 |
-
file_path = os.path.join(save_dir, filename)
|
42 |
-
with open(file_path, "wb") as f:
|
43 |
-
f.write(resp.content)
|
44 |
-
return file_path
|
45 |
-
|
46 |
-
@tool
|
47 |
-
def read_image(image_path: str) -> Image:
|
48 |
-
"""
|
49 |
-
Loads image from disk.
|
50 |
-
Args:
|
51 |
-
image_path (str): Path to the image file.
|
52 |
-
Returns:
|
53 |
-
The image.
|
54 |
-
"""
|
55 |
-
return Image.open(image_path)
|
56 |
-
|
57 |
-
@tool
|
58 |
-
def audio_to_text(audio_path: str) -> str:
|
59 |
-
"""
|
60 |
-
Converts audio (mp3/wav) to text using Google Speech Recognition.
|
61 |
-
Args:
|
62 |
-
audio_path (str): Path to the audio file.
|
63 |
-
Returns:
|
64 |
-
str: Recognized text.
|
65 |
-
"""
|
66 |
-
if audio_path.endswith(".mp3"):
|
67 |
-
source_file = audio_path.replace(".mp3", ".wav")
|
68 |
-
sound = AudioSegment.from_mp3(audio_path)
|
69 |
-
sound.export(source_file, format="wav")
|
70 |
-
else:
|
71 |
-
source_file = audio_path
|
72 |
-
r = sr.Recognizer()
|
73 |
-
audio_file = sr.AudioFile(source_file)
|
74 |
-
with audio_file as source:
|
75 |
-
audio = r.record(source)
|
76 |
-
text = r.recognize_google(audio)
|
77 |
-
return text
|
78 |
-
|
79 |
-
@tool
|
80 |
-
def extract_text_from_image(image_path: str) -> str:
|
81 |
-
"""
|
82 |
-
Extract text from image using pytesseract (OCR).
|
83 |
-
Args:
|
84 |
-
image_path: Path to the image file.
|
85 |
-
Returns:
|
86 |
-
Extracted text or error message.
|
87 |
-
"""
|
88 |
-
try:
|
89 |
-
import pytesseract
|
90 |
-
from PIL import Image
|
91 |
-
image = Image.open(image_path)
|
92 |
-
text = pytesseract.image_to_string(image)
|
93 |
-
return text
|
94 |
-
except ImportError:
|
95 |
-
return "Error: pytesseract is not installed."
|
96 |
-
except Exception as e:
|
97 |
-
return f"Error extracting text from image: {str(e)}"
|
98 |
-
|
99 |
-
# ==== AGENT ====
|
100 |
-
|
101 |
-
class GaiaAgent:
|
102 |
-
def __init__(self, model=None, max_steps=8):
|
103 |
-
# Jeśli model nie został przekazany, inicjalizuj domyślnie na OpenAI GPT-4o (lub inny)
|
104 |
-
if model is None:
|
105 |
-
api_key = os.getenv("OPENAI_API_KEY", "")
|
106 |
-
model = LiteLLMModel(
|
107 |
-
model_id="gpt-4o", # Zmień na swój model jeśli potrzeba
|
108 |
-
api_key=api_key,
|
109 |
-
)
|
110 |
-
self.gaia_agent = CodeAgent(
|
111 |
-
model=model,
|
112 |
-
tools=[
|
113 |
-
DuckDuckGoSearchTool(),
|
114 |
-
download_question_file,
|
115 |
-
read_image,
|
116 |
-
audio_to_text,
|
117 |
-
extract_text_from_image,
|
118 |
-
VisitWebpageTool(),
|
119 |
-
SpeechToTextTool()
|
120 |
-
],
|
121 |
-
additional_authorized_imports=["pandas", "numpy", "math", "statistics", "scipy"],
|
122 |
-
max_steps=max_steps
|
123 |
-
)
|
124 |
-
# Możesz dodać tu dodatkową konfigurację promptów jeśli chcesz.
|
125 |
-
|
126 |
-
def __call__(self, question: str) -> str:
|
127 |
-
print(f"Agent received question (first 50 chars): {question[:50]}...")
|
128 |
-
if self.gaia_agent:
|
129 |
-
try:
|
130 |
-
answer = self.gaia_agent.run(question)
|
131 |
-
print(f"Agent generated answer: {answer[:50]}..." if len(answer) > 50 else f"Agent generated answer: {answer}")
|
132 |
-
return answer
|
133 |
-
except Exception as e:
|
134 |
-
print(f"Error processing question: {e}")
|
135 |
-
return "An error occurred while processing your question. Please check the agent logs for details."
|
136 |
-
else:
|
137 |
-
return "The agent is not properly initialized. Please check your API keys and configuration."
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|