compatibility_date = "2022-04-05"
compatibility_flags = ["streams_enable_constructors"]