Skip to content
This repository was archived by the owner on Jun 6, 2025. It is now read-only.
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 10 additions & 3 deletions neurons/validator.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@

from agentao.base.validator import BaseValidatorNeuron, TaskType
from agentao.helpers.classes import GeneratedProblemStatement, IngestionHeuristics, \
IssueSolution
IssueSolution, convert_to_obj
from agentao.helpers.clients import LogSessionContext, setup_logger, LogContext
from agentao.helpers.constants import SUPPORTED_VALIDATOR_MODELS
from agentao.helpers.helpers import clone_repo, exponential_decay
Expand Down Expand Up @@ -199,7 +199,10 @@ async def forward(self):
self.logger.info(f"Problem statement is: {problem.problem_statement[:50]}...", extra=asdict(LogContext(
log_type="lifecycle",
event_type="question_generated",
additional_properties={"question_text": problem.problem_statement, "question_id": problem_uuid}
additional_properties={
"question_id": problem_uuid,
**convert_to_obj(problem),
}
)))

self.logger.info(f"Sending task {problem_uuid} ({problem.problem_statement[:50]}) to miners, ...")
Expand All @@ -220,7 +223,11 @@ async def forward(self):
self.logger.info(f"Received responses from miners for task {problem_uuid}", extra=asdict(LogContext(
log_type="lifecycle",
event_type="miner_submitted",
additional_properties={"miner_hotkey": r.axon.hotkey, "question_id": problem_uuid, "patch": r.patch}
additional_properties={
"miner_hotkey": r.axon.hotkey,
"question_id": problem_uuid,
"patch": r.patch
}
)))

working_miner_uids: List[int] = []
Expand Down
Loading