def register_task(self, key, wrapped_func):
        """Register a wrapped task and its key.

        This can executed later by calling Worker instances and passing them
        the same key used for registration.
        """
        if self.registry in key:
            raise ValueError('Implementation is already registered: %r' % (key, ))
        self.registry[key] = wrapped_func
dataset/ETHPy150Open severb/flowy/flowy/worker.py/Worker.register_task/swapped operands of `in`