diff --git a/vibi-dpu/src/core/trigger.rs b/vibi-dpu/src/core/trigger.rs
index e5c2e3aa..9def78dc 100644
--- a/vibi-dpu/src/core/trigger.rs
+++ b/vibi-dpu/src/core/trigger.rs
@@ -13,6 +13,7 @@ struct TriggerReview {
 pub async fn process_trigger(message_data: &Vec<u8>) {
 	// parse message
 	let parse_res = parse_trigger_msg(message_data);
+	log::debug!("[process_trigger] parse_res = {:?}", &parse_res);
 	// create review object from db
 	if parse_res.is_none() {
 		log::error!("[process_trigger] Unable to parse message: {:?}", &message_data);
diff --git a/vibi-dpu/src/graph/utils.rs b/vibi-dpu/src/graph/utils.rs
index aee60493..ca3e87b6 100644
--- a/vibi-dpu/src/graph/utils.rs
+++ b/vibi-dpu/src/graph/utils.rs
@@ -194,6 +194,7 @@ pub fn absolute_to_relative_path(abs_path: &str, review: &Review) -> Option<Stri
         return None;
     }
     let rel_path = rel_path_res.expect("Uncaught error in rel_path_res");
+    log::debug!("[absolute_to_relative_path] rel_path = {:?}", rel_path);
     return Some(rel_path.to_str().expect("Unable to deserialze rel_path").to_string());
 }
 
diff --git a/vibi-dpu/src/pubsub/listener.rs b/vibi-dpu/src/pubsub/listener.rs
index 3d43fc56..86d877f9 100644
--- a/vibi-dpu/src/pubsub/listener.rs
+++ b/vibi-dpu/src/pubsub/listener.rs
@@ -31,6 +31,7 @@ async fn process_message(attributes: &HashMap<String, String>, data_bytes: &Vec<
 		return;
 	}
 	let msgtype = msgtype_opt.expect("Empty msgtype");
+	log::debug!("[process_message] msgtype = {:?}", msgtype);
 	match msgtype.as_str() {
 		"install_callback" => {
 			process_install_callback(&data_bytes).await;
@@ -52,6 +53,7 @@ async fn process_message(attributes: &HashMap<String, String>, data_bytes: &Vec<
 		}
 		"manual_trigger" => {
 			log::info!("Processing trigger...");
+			log::debug!("[process_message] data_bytes = {:?}", &data_bytes);
 			process_trigger(&data_bytes).await;
 			log::info!("Trigger task processed!");
 		}
@@ -64,6 +66,7 @@ async fn process_message(attributes: &HashMap<String, String>, data_bytes: &Vec<
 			log::error!("[process_message] Message type not found for message : {:?}", attributes);
 		}
 	};
+	log::debug!("[process_message] msgtype.as_str() = {:?}", msgtype.as_str());
 }
 
 async fn process_install_callback(data_bytes: &[u8]) {
@@ -151,6 +154,7 @@ pub async fn listen_messages(keypath: &str, topicname: &str) {
 		log::info!("Recieved task, processing...");
 		let attrmap: HashMap<String, String> =
 			message.message.attributes.clone().into_iter().collect();
+		log::debug!("[listen_messages] attrmap = {:?}", &attrmap);
 		let message_hash = digest(&*message.message.data);
 		if !message_hashes.contains(&message_hash) {
 			message_hashes.push_back(message_hash);