diff --git a/build/ag_gen b/build/ag_gen
index 58421b6..f667db7 100755
Binary files a/build/ag_gen and b/build/ag_gen differ
diff --git a/src/ag_gen/ag_gen.cpp b/src/ag_gen/ag_gen.cpp
index 60be57c..8ca7329 100755
--- a/src/ag_gen/ag_gen.cpp
+++ b/src/ag_gen/ag_gen.cpp
@@ -1508,6 +1508,7 @@ AGGenInstance &AGGen::sg_generate(bool batch_process, int batch_num, int numThrd
             if(send_msg == 1){
                 world.isend(0, 2, 1);
                 send_msg = 0;
+                std::cout << "Node " << world.rank() << " finished subgraphing work." << std::endl;
                 if(localFrontier.size() > 0){
                     world.isend(0, 3, localFrontier);
                 }
@@ -1615,9 +1616,7 @@ AGGenInstance &AGGen::sg_generate(bool batch_process, int batch_num, int numThrd
                 */
             }
 
-            if(localFrontier.empty() && finish_count == world.size() -2){
-                finished_signal = 1;
-            }
+            std::cout << "Root received all signals from nodes" << std::endl;
 
             //Receive node frontiers and merge them into root frontier
             for(int w = 2; w < world.size(); w++){
@@ -1664,6 +1663,12 @@ AGGenInstance &AGGen::sg_generate(bool batch_process, int batch_num, int numThrd
                     }
                 }
             }
+
+
+            if(localFrontier.empty() && finish_count == world.size() -2){
+                finished_signal = 1;
+            }
+            
         } //end world rank 0
     } // end main work loop
 
@@ -1674,6 +1679,7 @@ AGGenInstance &AGGen::sg_generate(bool batch_process, int batch_num, int numThrd
         }
     }
 
+    std::cout << "Process " << world.rank() << " is finishing" << std::endl;
     world.barrier();
     if(world.rank() == 0){
         gettimeofday(&t2,NULL);