I'd still need an async interface up there, though? And there's no reason to validate the dont_have_join_key stream - they've already been partitioned such that we know the join key isn't an object