def METHOD_NAME(patch_incremental_base_class, mocker, current_stream_state, latest_record, expected_state):
    def __init__(self):
        self.timezone = pendulum.timezone("UTC")
    mocker.patch.object(IncrementalAppsflyerStream, "__init__", __init__)
    mocker.patch.object(IncrementalAppsflyerStream, "cursor_field", "event_time")
    stream = IncrementalAppsflyerStream()
    inputs = {"current_stream_state": current_stream_state, "latest_record": latest_record}
    assert stream.get_updated_state(**inputs) == expected_state