fix: add tx_submitter

packages/valory/skills/learning_abci/payloads.py

@@ -43,4 +43,5 @@ class DecisionMakingPayload(BaseTxPayload):
 class TxPreparationPayload(BaseTxPayload):
     """Represent a transaction payload for the TxPreparationRound."""
 
-    tx_hash: str
+    tx_submitter: Optional[str] = None
+    tx_hash: Optional[str] = None

packages/valory/skills/learning_abci/rounds.py

@@ -83,6 +83,11 @@ def participant_to_tx_round(self) -> DeserializedCollection:
         """Get the participants to the tx round."""
         return self._get_deserialized("participant_to_tx_round")
 
+    @property
+    def tx_submitter(self) -> str:
+        """Get the round that submitted a tx to transaction_settlement_abci."""
+        return str(self.db.get_strict("tx_submitter"))
+
 
 class APICheckRound(CollectSameUntilThresholdRound):
     """APICheckRound"""
@@ -128,7 +133,10 @@ class TxPreparationRound(CollectSameUntilThresholdRound):
     done_event = Event.DONE
     no_majority_event = Event.NO_MAJORITY
     collection_key = get_name(SynchronizedData.participant_to_tx_round)
-    selection_key = get_name(SynchronizedData.most_voted_tx_hash)
+    selection_key = (
+        get_name(SynchronizedData.tx_submitter),
+        get_name(SynchronizedData.most_voted_tx_hash),
+    )
 
     # Event.ROUND_TIMEOUT  # this needs to be referenced for static checkers