1. A method including: operations to process long tail task sequences in a stream processing framework in a computing grid, the operations including: operating a computing grid that includes a plurality of physical threads which processes data from one or more near real-time (NRT) data streams for multiple task sequences; queuing data from the one or more NRT data streams as batches in multiple pipelines using a grid-coordinator that controls dispatch of the batches to the physical threads; assigning a priority-level to each of the pipelines using a grid-scheduler, wherein the grid-scheduler initiates execution of a first number of batches from a first pipeline before execution of a second number of batches from a second pipeline, responsive to respective priority levels of the first and second pipelines; detecting that a NRT data stream is emitting measurably less data than before and determining that the NRT data stream should be classified as a long tail task sequence; in response to the determining, migrating the NRT data stream for the long tail task sequence to a low-priority pipeline; and processing data from the migrated NRT data stream using the low-priority pipeline.