469 missing information in ipfsagentresult

prediction_market_agent_tooling/deploy/agent.py

@@ -334,6 +334,10 @@ def update_langfuse_trace_by_processed_market(
             ]
         )
 
+    @property
+    def agent_name(self) -> str:
+        return self.__class__.__name__
+
     def check_min_required_balance_to_operate(self, market_type: MarketType) -> None:
         api_keys = APIKeys()
 
@@ -492,7 +496,9 @@ def after_process_market(
         processed_market: ProcessedMarket,
     ) -> None:
         keys = APIKeys()
-        market.store_prediction(processed_market=processed_market, keys=keys)
+        market.store_prediction(
+            processed_market=processed_market, keys=keys, agent_name=self.agent_name
+        )
 
     def before_process_markets(self, market_type: MarketType) -> None:
         """

prediction_market_agent_tooling/markets/agent_market.py

@@ -228,7 +228,10 @@ def verify_operational_balance(api_keys: APIKeys) -> bool:
         raise NotImplementedError("Subclasses must implement this method")
 
     def store_prediction(
-        self, processed_market: ProcessedMarket, keys: APIKeys
+        self,
+        processed_market: ProcessedMarket,
+        keys: APIKeys,
+        agent_name: str,
     ) -> None:
         """
         If market allows to upload predictions somewhere, implement it in this method.

prediction_market_agent_tooling/markets/omen/data_models.py

@@ -798,7 +798,7 @@ def from_tuple(values: tuple[t.Any]) -> "ContractPrediction":
 
 class IPFSAgentResult(BaseModel):
     reasoning: str
-
+    agent_name: str
     model_config = ConfigDict(
         extra="forbid",
     )

prediction_market_agent_tooling/markets/omen/omen.py

@@ -43,12 +43,12 @@
     ConditionPreparationEvent,
     ContractPrediction,
     CreatedMarket,
-    IPFSAgentResult,
     OmenBet,
     OmenMarket,
     OmenUserPosition,
     get_bet_outcome,
     get_boolean_outcome,
+    IPFSAgentResult,
 )
 from prediction_market_agent_tooling.markets.omen.omen_contracts import (
     OMEN_DEFAULT_MARKET_FEE_PERC,
@@ -417,20 +417,23 @@ def verify_operational_balance(api_keys: APIKeys) -> bool:
         ) > xdai_type(0.001)
 
     def store_prediction(
-        self, processed_market: ProcessedMarket, keys: APIKeys
+        self,
+        processed_market: ProcessedMarket,
+        keys: APIKeys,
+        agent_name: str,
     ) -> None:
-        reasoning = (
-            processed_market.answer.reasoning
-            if processed_market.answer.reasoning
-            else ""
-        )
-
         ipfs_hash_decoded = HexBytes(HASH_ZERO)
         if keys.enable_ipfs_upload:
             logger.info("Storing prediction on IPFS.")
-            ipfs_hash = IPFSHandler(keys).store_agent_result(
-                IPFSAgentResult(reasoning=reasoning)
+            reasoning = (
+                processed_market.answer.reasoning
+                if processed_market.answer.reasoning
+                else ""
+            )
+            agent_result = IPFSAgentResult(
+                reasoning=reasoning, agent_name=self.agent_name
             )
+            ipfs_hash = IPFSHandler(keys).store_agent_result(agent_result)
             ipfs_hash_decoded = ipfscidv0_to_byte32(ipfs_hash)
 
         tx_hashes = [