diff --git a/src/jetstream_consumer.py b/src/jetstream_consumer.py index 09492a9..782bc7f 100644 --- a/src/jetstream_consumer.py +++ b/src/jetstream_consumer.py @@ -292,10 +292,8 @@ async def process_event( # Get the thread containing the post. If a root post URI is provided, use that # to get the thread, otherwise use the post URI. - # thread_uri = root_post_uri if root_post_uri else post_uri - # logger.debug(f"Getting thread for {'root post' if root_post_uri else 'post'}", thread_uri) - - thread_uri = post_uri # note, removing this post for now in order to not seek the root post + thread_uri = root_post_uri if root_post_uri else post_uri + logger.debug(f"Getting thread for {'root post' if root_post_uri else 'post'}", thread_uri) # Use depth=0 to fetch the complete thread with all replies # This ensures we get all branches of the conversation