diff --git a/nexus/analyzer/src/qrep.rs b/nexus/analyzer/src/qrep.rs index 6bb2e729fa..7107d2728c 100644 --- a/nexus/analyzer/src/qrep.rs +++ b/nexus/analyzer/src/qrep.rs @@ -200,7 +200,7 @@ pub fn process_options( // If mode is upsert, we need unique key columns if opts.get("mode") == Some(&Value::String(String::from("upsert"))) - && (opts.get("unique_key_columns") == None + && (opts.get("unique_key_columns").is_none() || opts.get("unique_key_columns") == Some(&Value::Array(vec![]))) { anyhow::bail!("For upsert mode, unique_key_columns must be specified");