Add comments around the necessity of _parent_task and _pool on `M…

…icrobatchModelRunner`
dbt-labs · Mar 3, 2025 · ef461da · ef461da
1 parent a32a7ae
commit ef461da
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/core/dbt/task/run.py b/core/dbt/task/run.py
@@ -562,7 +562,9 @@ class MicrobatchModelRunner(ModelRunner):
     def __init__(self, config, adapter, node, node_index: int, num_nodes: int):
         super().__init__(config, adapter, node, node_index, num_nodes)
 
+        # The parent task is necessary because we need access to the `_submit_batch` and `submit` methods
         self._parent_task: Optional[RunTask] = None
+        # The pool is necessary because we need to batches to be executed within the same thread pool
         self._pool: Optional[DbtThreadPool] = None
 
     def set_parent_task(self, parent_task: RunTask) -> None: