try thing

app.py

@@ -162,8 +162,8 @@ def pipeline_callback(output_queue: SimpleQueue, pipe: Any, step_index: int, tim
     image = pipe.vae.decode(latents / pipe.vae.config.scaling_factor, return_dict=False)[0]  # type: ignore[attr-defined]
     image = pipe.image_processor.postprocess(image, output_type="np").squeeze()  # type: ignore[attr-defined]
 
-    # output_queue.put(("log", "mvs/image", rr.Image(image)))
-    # output_queue.put(("log", "mvs/latents", rr.Tensor(latents.squeeze())))
+    output_queue.put(("log", "mvs/image", rr.Image(image)))
+    output_queue.put(("log", "mvs/latents", rr.Tensor(latents.squeeze())))
 
     return callback_kwargs
 
@@ -294,24 +294,24 @@ def log_to_rr(input_image, do_remove_background, sample_steps, sample_seed):
 
     output_queue = SimpleQueue()
 
-    # mvs_thread = threading.Thread(target=generate_mvs, args=[output_queue, input_image, sample_steps, sample_seed])
-    # mvs_thread.start()
-
-    # while True:
-    #     msg = output_queue.get()
-    #     if msg[0] == "z123_image":
-    #         z123_image = msg[1]
-    #         break
-    #     elif msg[0] == "log":
-    #         entity_path = msg[1]
-    #         entity = msg[2]
-    #         rr.log(entity_path, entity)
-    #         yield stream.read()
+    mvs_thread = threading.Thread(target=generate_mvs, args=[output_queue, input_image, sample_steps, sample_seed])
+    mvs_thread.start()
+
+    while True:
+        msg = output_queue.get()
+        if msg[0] == "z123_image":
+            z123_image = msg[1]
+            break
+        elif msg[0] == "log":
+            entity_path = msg[1]
+            entity = msg[2]
+            rr.log(entity_path, entity)
+            yield stream.read()
     
-    # mvs_thread.join()
+    mvs_thread.join()
 
-    # rr.log("z123image", rr.Image(z123_image))
-    # yield stream.read()
+    rr.log("z123image", rr.Image(z123_image))
+    yield stream.read()
 
     # mesh_fpath, mesh_glb_fpath = make3d(output_queue, z123_image)