if (selector_meta_data, self.index) in source.stream_id.meta_data:
                found_source = True
                for item in map(lambda x: StreamMetaInstance(x, source.stream_id.meta_data),
                                source.window(interval, force_calculation=True)):
                    found_data_in_source = True