def iter_results()

in pythonflow/pfmq/task.py [0:0]

• 19 lines of code
• 7 McCabe index (conditional complexity)

    def iter_results(self, timeout=None):
        """
        Iterate over the results.

        Parameters
        ----------
        timeout : float
            Timeout for getting results.
        """
        while True:
            status, result = self.results.get(timeout=timeout)
            if status == 'ok':
                yield result
            elif status in 'error':
                value, tb = result
                LOGGER.error(tb)
                raise value
            elif status == 'timeout':
                raise result
            elif status == 'end':
                return
            elif status == 'serialization_error':
                raise SerializationError(
                    "failed to serialize result for request with identifier %s" % result
                )
            else:
                raise KeyError(status)  # pragma: no cover