code: def subscribe_condition_fulfilled(self, agreement_id, timeout, callback, args,
                                        timeout_callback=None, wait=False):
          
          logger.info(
              f'Subscribing {self.FULFILLED_EVENT} event with agreement id {agreement_id}.')
          return self.subscribe_to_event(
              self.FULFILLED_EVENT,
              timeout,
              {'_agreementId': Web3Provider.get_web3().toBytes(hexstr=agreement_id)},
              callback=callback,
              timeout_callback=timeout_callback,
              args=args,
              wait=wait
          )
docs: Subscribe to the condition fullfilled event.
  
          :param agreement_id: id of the agreement, hex str
          :param timeout:
          :param callback:
          :param args:
          :param timeout_callback:
          :param wait: if true block the listener until get the event, bool
          :return: