                             profile: @state.options.profile
                         connection_error: (error) =>
                             @error_on_connect error
-                        callback: query_result.set
+                        callback: (error, result) =>
+                            if final_query
+                                query_result.set error, result
+                            else if error
+                                @result_view.render_error(@query, err)
+                            else
+                                @execute_portion()
 
                     return true
                 else


                @index++
                if rdb_query instanceof @TermBaseConstructor
                    @start_time = new Date()

                    query_result = new QueryResult
                        has_profile: @state.options.profiler
                        current_query: @raw_query
                        raw_query: @raw_queries[@index]
                        driver_handler: @driver_handler
                        events:
                            error: (err) =>
                                @results_view.render_error(@query, err)

                    # ATN: pass the query_result object to the view

                    @driver_handler.run_with_new_connection rdq_query,
                        optargs:

                        @save_query
                            query: @raw_query
                            broken_query: true

        # ATN: move to child views
        # Called when there is a new batch of results to display
