async def storm(self, text, opts=None, user=None):
        '''
        Execute a storm query and yield (Node(), Path()) tuples.
        '''
        if user is None:
            user = self.user

        query = self.core.getStormQuery(text)
        with self.getStormRuntime(opts=opts, user=user) as runt:
            async for x in runt.iterStormQuery(query):
                yield x
async def storm ( self , text , opts = None , user = None ) : if user is None : user = self . user query = self . core . getStormQuery ( text ) with self . getStormRuntime ( opts = opts , user = user ) as runt : async for x in runt . iterStormQuery ( query ) : yield x
Execute a storm query and yield (Node(), Path()) tuples.