def METHOD_NAME(
    self, windowed_input_element, results, watermark_estimator=None
):
    print(windowed_input_element)
    try:
        for result in results:
            assert result
    except StopIteration:
        print("In here")