diff --git a/scripts/_LDRD_Kafka.py b/scripts/_LDRD_Kafka.py
index 9f5fba6..442cd85 100644
--- a/scripts/_LDRD_Kafka.py
+++ b/scripts/_LDRD_Kafka.py
@@ -231,7 +231,7 @@ def macro_agent(self, qserver_process, RM, check_target=False):
         meet_target = (peak_diff <= peak_tolerance)
 
         if check_target and meet_target:
-            print(f'\nTarget peak: {self.inputs.peak_target[0]} nm vs. Current peak: {self.PL_fitting['peak_emission']} nm\n')
+            print(f'\nTarget peak: {self.inputs.peak_target[0]} nm vs. Current peak: {self.PL_fitting["peak_emission"]} nm\n')
             print(f'\nReach the target, stop iteration, stop all pumps, and wash the loop.\n')
 
             ### Stop all infusing pumps and wash loop
@@ -822,7 +822,7 @@ def macro_15_save_data(self, stream_name):
         """
         
         ## Save fitting data
-        print(f'\nFitting function: {self.PL_fitting['fit_function']}\n')
+        print(f'\nFitting function: {self.PL_fitting["fit_function"]}\n')
         de.dic_to_csv_for_stream(self.inputs.csv_path[0], 
                                 self.qepro_dic, 
                                 self.metadata_dic, 
diff --git a/scripts/kafka_consumer_iterate_XPD_v2.py b/scripts/kafka_consumer_iterate_XPD_v2.py
index 9d0b6d9..8eed05c 100644
--- a/scripts/kafka_consumer_iterate_XPD_v2.py
+++ b/scripts/kafka_consumer_iterate_XPD_v2.py
@@ -403,9 +403,9 @@ def print_message(consumer, doctype, doc, check_abs365 = False, agent_iteration
             
 
             #################  macro_17_add_queue: Add queus task to qserver  ###################
-            ##                                                                                 ##
             ##        Depend on # of good/bad data, add items into queue item or stop          ##
-            ##                   'take_a_uvvis' or new_points of self.agent                    ##
+            ##                     Add nother 'take_a_uvvis' into queue                        ##
+            ##          Make prediction by self.agent and add new_points to queue              ##
             ##################################################################################### 
             kafka_process.macro_17_add_queue(stream_name, qserver_process, RM)