labgraph/runners/local_runner.py [325:340]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            root_stream_id = local_stream_id
            if self._options.bootstrap_info is not None:
                if self._options.bootstrap_info.stream_namespace is not None:
                    root_topic_path = (
                        f"{self._options.bootstrap_info.stream_namespace}"
                        f"{PATH_DELIMITER}{root_topic_path}"
                    )
                root_stream_id = self._options.bootstrap_info.stream_ids_by_topic_path[
                    root_topic_path
                ]

            cthulhu_stream = get_stream(root_stream_id)
            assert cthulhu_stream is not None, (
                f"Cthulhu stream for topic {root_topic_path} ({root_stream_id}) was "
                "not created"
            )
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



labgraph/runners/local_runner.py [381:395]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            root_stream_id = local_stream_id
            if self._options.bootstrap_info is not None:
                if self._options.bootstrap_info.stream_namespace is not None:
                    root_topic_path = (
                        f"{self._options.bootstrap_info.stream_namespace}"
                        f"{PATH_DELIMITER}{root_topic_path}"
                    )
                root_stream_id = self._options.bootstrap_info.stream_ids_by_topic_path[
                    root_topic_path
                ]
            cthulhu_stream = get_stream(root_stream_id)
            assert cthulhu_stream is not None, (
                f"Cthulhu stream for topic {root_topic_path} ({root_stream_id}) was "
                "not created"
            )
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -