diff --git a/engines/dfc_provider/app/services/affiliate_sales_query.rb b/engines/dfc_provider/app/services/affiliate_sales_query.rb
index a2a90ad233..155243745a 100644
--- a/engines/dfc_provider/app/services/affiliate_sales_query.rb
+++ b/engines/dfc_provider/app/services/affiliate_sales_query.rb
@@ -50,7 +50,7 @@ class AffiliateSalesQuery
       <<~SQL.squish
         spree_products.name AS product_name,
         spree_variants.display_name AS unit_name,
-        spree_products.variant_unit AS unit_type,
+        spree_variants.variant_unit AS unit_type,
         spree_variants.unit_value AS units,
         spree_variants.unit_presentation,
         spree_line_items.price,
diff --git a/engines/dfc_provider/spec/services/affiliate_sales_query_spec.rb b/engines/dfc_provider/spec/services/affiliate_sales_query_spec.rb
index b90b410576..40852fbae8 100644
--- a/engines/dfc_provider/spec/services/affiliate_sales_query_spec.rb
+++ b/engines/dfc_provider/spec/services/affiliate_sales_query_spec.rb
@@ -61,7 +61,6 @@ RSpec.describe AffiliateSalesQuery do
     it "returns data" do
       labelled_row = query.label_row(query.data(order1.distributor).first)
 
-      pending "unit_type"
       expect(labelled_row).to include(
         product_name: "Tomatoes",
         unit_name: "Tomatoes - Roma",