kytos-ng / kytos

            and also decorated as an asyncio task.

        """

        # pylint: disable=unused-argument,broad-except

        async def handler_context(*args, **kwargs):

            """Async handler's execution context."""

            cls, kytos_event = args[0], args[1]

            try:

                result = await handler(*args)

            except Exception:

                result = None

                traceback_str = traceback.format_exc()

                LOG.error(f"alisten_to handler: {handler}, "

                          f"args: {args} traceback: {traceback_str}")

                if hasattr(cls, "controller"):

                    cls.controller.dead_letter.add_event(kytos_event)

            return result

        async def handler_context_apm(*args, apm_client=None):

            """Async handler's execution context with APM instrumentation."""

                return

        # pylint: disable=unused-argument

        def handler_context(*args, **kwargs):

            """Handler's context for ThreadPool."""

            cls, kytos_event = args[0], args[1]

            try:

                result = handler(*args)

            except Exception:

                result = None

                traceback_str = traceback.format_exc()

                LOG.error(f"listen_to handler: {handler}, "

                          f"args: {args} traceback: {traceback_str}")

                if hasattr(cls, "controller"):

                    cls.controller.dead_letter.add_event(kytos_event)

            return result

        def handler_context_apm(*args, apm_client=None):

            """Handler's context for ThreadPool APM instrumentation."""