machine.py 文件源码

def execute(self, **kwargs):
        """
        Runs the fulfillment strategy on the initiator until the conditions are met.

        :return:
        """
        with gevent.Timeout(self.timeout):
            result = self.fulfillment.run(self.initiator, self.conditions, **kwargs)
            result.event_name = self.name
            return result