def imap()

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

• 4 lines of code
• 2 McCabe index (conditional complexity)

    def imap(self, requests, **kwargs):
        """
        Process a sequence of requests remotely.

        Parameters
        ----------
        requsests : iterable
            Sequence of requests to process.

        Returns
        -------
        task : Task
            Remote task that can be iterated over.
        """
        if not self.is_alive:
            raise RuntimeError("broker is not running")
        return Task(requests, self.frontend_address, **kwargs)