Right now, there's an overall timeout for each query and if it's hit, the query is automatically sent back regardless of where it is in the pipeline. And the pipeline will continue regardless of if the query has already been sent back or not. We should add a check when getting tasks to see if the query has been "completed" yet and only do the task if it's still in a running state.