docs: def get_aggregate_by_id(self, tx_id: str) -> ScheduledTxAggregate:
          """ Creates an aggregate for single entity """
          tran = self.get_by_id(tx_id)
          return self.get_aggregate_for(tran)