Method run

src/memos/context/context.py:224–241

(self)

        self.main_context = get_current_context()

    def run(self):
        # Create a new RequestContext with the main thread's trace_id
        if self.main_context:
            # Copy the context data
            child_context = RequestContext(
                trace_id=self.main_trace_id,
                api_path=self.main_api_path,
                env=self.main_env,
                user_type=self.main_user_type,
                user_name=self.main_user_name,
            )
            child_context._data = self.main_context._data.copy()

            # Set the context in the child thread
            set_request_context(child_context)

        # Run the target function
        self.target(*self.args, **self.kwargs)


class ContextThreadPoolExecutor(ThreadPoolExecutor):