for sink in sinks:
            if interval.end > sink.channel.up_to_timestamp:
                raise ValueError('The stream is not available after {} and cannot be calculated'
                                 .format(sink.channel.up_to_timestamp))
            if calculated_intervals is None: