U [eY%@sNddlZddlmZddlmZeeZGdddeZGdddeZ dS) N)EnabledExtensionManager) NoMatchesc@s eZdZdZddZddZdS)DispatchExtensionManageraFLoads all plugins and filters on execution. This is useful for long-running processes that need to pass different inputs to different extensions. :param namespace: The namespace for the entry points. :type namespace: str :param check_func: Function to determine which extensions to load. :type check_func: callable :param invoke_on_load: Boolean controlling whether to invoke the object returned by the entry point after the driver is loaded. :type invoke_on_load: bool :param invoke_args: Positional arguments to pass when invoking the object returned by the entry point. Only used if invoke_on_load is True. :type invoke_args: tuple :param invoke_kwds: Named arguments to pass when invoking the object returned by the entry point. Only used if invoke_on_load is True. :type invoke_kwds: dict :param propagate_map_exceptions: Boolean controlling whether exceptions are propagated up through the map call or whether they are logged and then ignored :type invoke_on_load: bool cOsL|jstd|jg}|jD](}||f||r||j||||q|S)a|Iterate over the extensions invoking func() for any where filter_func() returns True. The signature of filter_func() should be:: def filter_func(ext, *args, **kwds): pass The first argument to filter_func(), 'ext', is the :class:`~stevedore.extension.Extension` instance. filter_func() should return True if the extension should be invoked for the input arguments. The signature for func() should be:: def func(ext, *args, **kwds): pass The first argument to func(), 'ext', is the :class:`~stevedore.extension.Extension` instance. Exceptions raised from within func() are propagated up and processing stopped if self.propagate_map_exceptions is True, otherwise they are logged and ignored. :param filter_func: Callable to test each extension. :param func: Callable to invoke for each extension. :param args: Variable arguments to pass to func() :param kwds: Keyword arguments to pass to func() :returns: List of values returned from func() zNo %s extensions found) extensionsr namespace_invoke_one_pluginappend)self filter_funcfuncargskwdsresponseerT/var/www/html/services/stratfitenv/lib/python3.8/site-packages/stevedore/dispatch.pymap0s  zDispatchExtensionManager.mapcOs|j||j|f||S)aUIterate over the extensions invoking each one's object method called `method_name` for any where filter_func() returns True. This is equivalent of using :meth:`map` with func set to `lambda x: x.obj.method_name()` while being more convenient. Exceptions raised from within the called method are propagated up and processing stopped if self.propagate_map_exceptions is True, otherwise they are logged and ignored. .. versionadded:: 0.12 :param filter_func: Callable to test each extension. :param method_name: The extension method name to call for each extension. :param args: Variable arguments to pass to method :param kwds: Keyword arguments to pass to method :returns: List of values returned from methods rZ_call_extension_method)r r method_namer rrrr map_methodYs z#DispatchExtensionManager.map_methodN)__name__ __module__ __qualname____doc__rrrrrrrs)rcsJeZdZdZddidddffdd ZfddZd d Zd d ZZS) NameDispatchExtensionManagera6Loads all plugins and filters on execution. This is useful for long-running processes that need to pass different inputs to different extensions and can predict the name of the extensions before calling them. The check_func argument should return a boolean, with ``True`` indicating that the extension should be loaded and made available and ``False`` indicating that the extension should be ignored. :param namespace: The namespace for the entry points. :type namespace: str :param check_func: Function to determine which extensions to load. :type check_func: callable :param invoke_on_load: Boolean controlling whether to invoke the object returned by the entry point after the driver is loaded. :type invoke_on_load: bool :param invoke_args: Positional arguments to pass when invoking the object returned by the entry point. Only used if invoke_on_load is True. :type invoke_args: tuple :param invoke_kwds: Named arguments to pass when invoking the object returned by the entry point. Only used if invoke_on_load is True. :type invoke_kwds: dict :param propagate_map_exceptions: Boolean controlling whether exceptions are propagated up through the map call or whether they are logged and then ignored :type invoke_on_load: bool :param on_load_failure_callback: Callback function that will be called when an entrypoint can not be loaded. The arguments that will be provided when this is called (when an entrypoint fails to load) are (manager, entrypoint, exception) :type on_load_failure_callback: function :param verify_requirements: Use setuptools to enforce the dependencies of the plugin(s) being loaded. Defaults to False. :type verify_requirements: bool FrNc s$tt|j||||||||ddS)N)r check_funcinvoke_on_load invoke_args invoke_kwdspropagate_map_exceptionson_load_failure_callbackverify_requirements)superr__init__) r rrrrrr r!r" __class__rrr$s z%NameDispatchExtensionManager.__init__cs*tt||tdd|jD|_dS)Ncss|]}|j|fVqdS)N)name).0rrrr sz=NameDispatchExtensionManager._init_plugins..)r#r _init_pluginsdictrby_name)r rr%rrr*sz*NameDispatchExtensionManager._init_pluginsc OsVg}|D]H}z|j|}Wn tk r:td|YqX||j||||q|S)a5Iterate over the extensions invoking func() for any where the name is in the given list of names. The signature for func() should be:: def func(ext, *args, **kwds): pass The first argument to func(), 'ext', is the :class:`~stevedore.extension.Extension` instance. Exceptions raised from within func() are propagated up and processing stopped if self.propagate_map_exceptions is True, otherwise they are logged and ignored. :param names: List or set of name(s) of extension(s) to invoke. :param func: Callable to invoke for each extension. :param args: Variable arguments to pass to func() :param kwds: Keyword arguments to pass to func() :returns: List of values returned from func() z"Missing extension %r being ignored)r,KeyErrorLOGdebugrr )r namesr r rrr'rrrrrsz NameDispatchExtensionManager.mapcOs|j||j|f||S)alIterate over the extensions invoking each one's object method called `method_name` for any where the name is in the given list of names. This is equivalent of using :meth:`map` with func set to `lambda x: x.obj.method_name()` while being more convenient. Exceptions raised from within the called method are propagated up and processing stopped if self.propagate_map_exceptions is True, otherwise they are logged and ignored. .. versionadded:: 0.12 :param names: List or set of name(s) of extension(s) to invoke. :param method_name: The extension method name to call for each extension. :param args: Variable arguments to pass to method :param kwds: Keyword arguments to pass to method :returns: List of values returned from methods r)r r0rr rrrrrs z'NameDispatchExtensionManager.map_method) rrrrr$r*rr __classcell__rrr%rrrs(  r) loggingenabledr exceptionr getLoggerrr.rrrrrr s    ]