From 6c835ec468bfb487f23a6dcbf19b87f523767618 Mon Sep 17 00:00:00 2001
From: Hammad Bashir <HammadB@users.noreply.github.com>
Date: Wed, 24 Jan 2024 15:49:47 -0800
Subject: [PATCH] More rust logs (#1679)

More logs
---
 rust/worker/src/ingest/ingest.rs | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/rust/worker/src/ingest/ingest.rs b/rust/worker/src/ingest/ingest.rs
index 0cd11bfc656..fee60acb456 100644
--- a/rust/worker/src/ingest/ingest.rs
+++ b/rust/worker/src/ingest/ingest.rs
@@ -324,6 +324,10 @@ impl Component for PulsarIngestTopic {
         let stream = stream.then(|result| async {
             match result {
                 Ok(msg) => {
+                    println!(
+                        "PulsarIngestTopic received message with id: {:?}",
+                        msg.message_id
+                    );
                     // Convert the Pulsar Message to an EmbeddingRecord
                     let proto_embedding_record = msg.deserialize();
                     let id = msg.message_id;
@@ -336,12 +340,14 @@ impl Component for PulsarIngestTopic {
                         }
                         Err(err) => {
                             // TODO: Handle and log
+                            println!("PulsarIngestTopic received error while performing conversion: {:?}", err);
                         }
                     }
                     None
                 }
                 Err(err) => {
                     // TODO: Log an error
+                    println!("PulsarIngestTopic received error: {:?}", err);
                     // Put this on a dead letter queue, this concept does not exist in our
                     // system yet
                     None