def apply()

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

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

    def apply(self, request, **kwargs):
        """
        Process a request remotely.

        Parameters
        ----------
        request : object
            Request to process.

        Returns
        -------
        ressult : object
            Result of remotely-processed request.
        """
        if not self.is_alive:
            raise RuntimeError("broker is not running")

        return apply(request, self.frontend_address, **kwargs)