Function async_run

dash/background_callback/managers/diskcache_manager.py:260–298

()

                cache.set(result_key, user_callback_output)

        async def async_run():
            c = AttributeDict(**context)
            c.ignore_register_page = False
            c.updated_props = ProxySetProps(_set_props)
            context_value.set(c)
            errored = False
            try:
                if isinstance(user_callback_args, dict):
                    user_callback_output = await fn(
                        *maybe_progress, **user_callback_args
                    )
                elif isinstance(user_callback_args, (list, tuple)):
                    user_callback_output = await fn(
                        *maybe_progress, *user_callback_args
                    )
                else:
                    user_callback_output = await fn(*maybe_progress, user_callback_args)
            except PreventUpdate:
                errored = True
                cache.set(result_key, {"_dash_no_update": "_dash_no_update"})
            except Exception as err:  # pylint: disable=broad-except
                errored = True
                cache.set(
                    result_key,
                    {
                        "background_callback_error": {
                            "msg": str(err),
                            "tb": traceback.format_exc(),
                        }
                    },
                )

            if asyncio.iscoroutine(user_callback_output):
                user_callback_output = await user_callback_output
            if not errored:
                try:
                    cache.set(result_key, user_callback_output)
                except Exception as err:  # pylint: disable=broad-except
                    print(f"Diskcache manager couldn't save output: {err}")

        if inspect.iscoroutinefunction(fn):
            func = partial(ctx.run, async_run)