def callback(result):
            """Note: mark_done, at a minimum, must happen here or dbt will
            deadlock during ephemeral result error handling!
            """
            self._handle_result(result)

            if self.job_queue is None:
                raise DbtInternalError("Got to run_queue callback with no job queue set")
            self.job_queue.mark_done(result.node.unique_id)
Note: mark_done, at a minimum, must happen here or dbt will
            deadlock during ephemeral result error handling!
            
core/dbt/task/runnable.py