-record(primary_key_changed, {old_pk :: list(binary()), new_pk :: list(binary())}).