def update_computed_intervals(sinks, time_interval):
        """
        Update computed intervals

        :param sinks: The streams to update
        :param time_interval: The time interval
        """
        for sink in sinks:
            sink.calculated_intervals += time_interval
            required_intervals = TimeIntervals([time_interval]) - sink.calculated_intervals
            if not required_intervals.is_empty:
                raise RuntimeError('Tool execution did not cover the time interval {}'
                                   .format(required_intervals))
def update_computed_intervals ( sinks , time_interval ) : for sink in sinks : sink . calculated_intervals += time_interval required_intervals = TimeIntervals ( [ time_interval ] ) - sink . calculated_intervals if not required_intervals . is_empty : raise RuntimeError ( 'Tool execution did not cover the time interval {}' . format ( required_intervals ) )
Update computed intervals

        :param sinks: The streams to update
        :param time_interval: The time interval