From 8aa6d59a3e7bf4e34948ca51d379bed46d02d0a0 Mon Sep 17 00:00:00 2001
From: James McKinney <26463+jpmckinney@users.noreply.github.com>
Date: Fri, 24 May 2024 21:14:24 -0400
Subject: [PATCH] fix: Don't copy ancestor's meta, to avoid indicating
 incorrect counts

---
 workers/extract/dataset_filter.py     | 2 +-
 workers/extract/kingfisher_process.py | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/workers/extract/dataset_filter.py b/workers/extract/dataset_filter.py
index aadd296..541436c 100644
--- a/workers/extract/dataset_filter.py
+++ b/workers/extract/dataset_filter.py
@@ -79,7 +79,7 @@ def callback(client_state, channel, method, properties, input_message):
         cursor.execute(
             """\
             INSERT INTO dataset (name, meta, ancestor_id)
-            SELECT name, meta, NULL FROM dataset WHERE id = %(dataset_id)s
+            SELECT name, '{}'::jsonb, NULL FROM dataset WHERE id = %(dataset_id)s
             RETURNING id
             """,
             {"dataset_id": dataset_id_original},
diff --git a/workers/extract/kingfisher_process.py b/workers/extract/kingfisher_process.py
index 25d98c3..b4945d6 100644
--- a/workers/extract/kingfisher_process.py
+++ b/workers/extract/kingfisher_process.py
@@ -58,10 +58,10 @@ def callback(client_state, channel, method, properties, input_message):
             cursor.execute(
                 """\
                 INSERT INTO dataset (name, meta, ancestor_id)
-                VALUES (%(name)s, %(meta)s, %(ancestor_id)s)
+                VALUES (%(name)s, '{}'::jsonb, %(ancestor_id)s)
                 RETURNING id
                 """,
-                {"name": name, "meta": Json({}), "ancestor_id": ancestor_id},
+                {"name": name, "ancestor_id": ancestor_id},
             )
             dataset_id = cursor.fetchone()[0]