Index: trunk/ippTools/share/disttool_definebyquery_camera.sql
===================================================================
--- trunk/ippTools/share/disttool_definebyquery_camera.sql	(revision 26515)
+++ trunk/ippTools/share/disttool_definebyquery_camera.sql	(revision 26519)
@@ -5,4 +5,5 @@
     camRun.magicked,
     camRun.label,
+    camRun.data_group,
     distTarget.dist_group,
     distTarget.target_id,
Index: trunk/ippTools/share/disttool_definebyquery_chip.sql
===================================================================
--- trunk/ippTools/share/disttool_definebyquery_chip.sql	(revision 26515)
+++ trunk/ippTools/share/disttool_definebyquery_chip.sql	(revision 26519)
@@ -5,4 +5,5 @@
     rawExp.exp_name as run_tag,
     chipRun.label,
+    chipRun.data_group,
     chipRun.dist_group,
     distTarget.target_id,
Index: trunk/ippTools/share/disttool_definebyquery_diff.sql
===================================================================
--- trunk/ippTools/share/disttool_definebyquery_diff.sql	(revision 26515)
+++ trunk/ippTools/share/disttool_definebyquery_diff.sql	(revision 26519)
@@ -5,4 +5,5 @@
     rawExp.exp_name as run_tag,
     diffRun.label,
+    diffRun.data_group,
     distTarget.dist_group,
     distTarget.target_id,
Index: trunk/ippTools/share/disttool_definebyquery_fake.sql
===================================================================
--- trunk/ippTools/share/disttool_definebyquery_fake.sql	(revision 26515)
+++ trunk/ippTools/share/disttool_definebyquery_fake.sql	(revision 26519)
@@ -5,4 +5,5 @@
     rawExp.exp_name as run_tag,
     fakeRun.label,
+    fakeRun.data_group,
     distTarget.dist_group,
     distTarget.target_id,
Index: trunk/ippTools/share/disttool_definebyquery_raw.sql
===================================================================
--- trunk/ippTools/share/disttool_definebyquery_raw.sql	(revision 26515)
+++ trunk/ippTools/share/disttool_definebyquery_raw.sql	(revision 26519)
@@ -5,4 +5,5 @@
     rawExp.magicked,
     chipRun.label,
+    chipRun.data_group,
     distTarget.dist_group,
     distTarget.target_id,
Index: trunk/ippTools/share/disttool_definebyquery_stack.sql
===================================================================
--- trunk/ippTools/share/disttool_definebyquery_stack.sql	(revision 26515)
+++ trunk/ippTools/share/disttool_definebyquery_stack.sql	(revision 26519)
@@ -6,4 +6,5 @@
     CONCAT_WS('.', 'stack', stackRun.skycell_id, convert(stackRun.stack_id, CHAR)) as run_tag,
     stackRun.label,
+    stackRun.data_group,
     distTarget.dist_group,
     distTarget.target_id,
Index: trunk/ippTools/share/disttool_definebyquery_warp.sql
===================================================================
--- trunk/ippTools/share/disttool_definebyquery_warp.sql	(revision 26515)
+++ trunk/ippTools/share/disttool_definebyquery_warp.sql	(revision 26519)
@@ -5,4 +5,5 @@
     rawExp.exp_name as run_tag,
     warpRun.label,
+    warpRun.data_group,
     distTarget.dist_group,
     distTarget.target_id,
Index: trunk/ippTools/share/disttool_pendingfileset.sql
===================================================================
--- trunk/ippTools/share/disttool_pendingfileset.sql	(revision 26515)
+++ trunk/ippTools/share/disttool_pendingfileset.sql	(revision 26519)
@@ -5,7 +5,5 @@
     distRun.outdir as dist_dir,
     stage_id,
-    -- we need to get data_group here but we don't have
-    -- the right tables joined. Perhaps we need to add that column to distRun
-    distRun.label as data_group,
+    distRun.data_group,
     distTarget.filter,
     rcDestination.name AS product_name,
Index: trunk/ippTools/share/pxadmin_create_tables.sql
===================================================================
--- trunk/ippTools/share/pxadmin_create_tables.sql	(revision 26515)
+++ trunk/ippTools/share/pxadmin_create_tables.sql	(revision 26519)
@@ -1352,4 +1352,5 @@
     time_stamp  TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
     fault       SMALLINT,
+    data_group  VARCHAR(64),
     note        VARCHAR(255),
     PRIMARY KEY(dist_id),
Index: trunk/ippTools/src/disttool.c
===================================================================
--- trunk/ippTools/src/disttool.c	(revision 26515)
+++ trunk/ippTools/src/disttool.c	(revision 26519)
@@ -358,4 +358,5 @@
         psS64 target_id = psMetadataLookupS64(NULL, md, "target_id");
         psString stage_label = psMetadataLookupStr(NULL, md, "label");
+        psString data_group = psMetadataLookupStr(NULL, md, "data_group");
         bool clean = psMetadataLookupBool(NULL, md, "clean");
 
@@ -383,4 +384,5 @@
                 NULL,    // time_stamp
                 0,       // fault
+                data_group,
                 set_note // note does not propagate
                 );