Correctly set have more output

cwida · Dec 13, 2024 · ef407da · ef407da
1 parent d10d08d
commit ef407da
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/core/operator/physical_path_finding_operator.cpp b/src/core/operator/physical_path_finding_operator.cpp
@@ -226,7 +226,10 @@ SourceResultType PhysicalPathFinding::GetData(ExecutionContext &context, DataChu
   std::cout << "Batch list length: " << current_state->current_batch_path_list_len << std::endl;
 
   pf_sink.result_scan_idx++;
-  return SourceResultType::FINISHED;
+  if (pf_sink.result_scan_idx == pf_sink.bfs_states.size()) {
+    return SourceResultType::FINISHED;
+  }
+  return SourceResultType::HAVE_MORE_OUTPUT;
 }
 
 //===--------------------------------------------------------------------===//