diff --git a/ldv_migrate/ldv_migrate/migrate_ldvadmin_to_ldvspec.py b/ldv_migrate/ldv_migrate/migrate_ldvadmin_to_ldvspec.py
index 901f2740006835115209713b798190dbae05d643..ceff904f87d787f0a3bc226c3d3174da01ff91e4 100644
--- a/ldv_migrate/ldv_migrate/migrate_ldvadmin_to_ldvspec.py
+++ b/ldv_migrate/ldv_migrate/migrate_ldvadmin_to_ldvspec.py
@@ -164,7 +164,7 @@ def main():
     query_count_all_raw_dataproducts = "select count(*) from astrowise.raw_dataproducts"
     query_count_all_pipeline_dataproducts = "select count(*) from astrowise.pl_dataproducts"
     query_all_required_fields_raw_dataproducts = \
-        "select obsid, obsid_source, dp_type, project, activity, uri, size, dysco, antenna_set, instrument_filter, from astrowise.raw_dataproducts order by id {}" \
+        "select obsid, obsid_source, dp_type, project, activity, uri, size, dysco, antenna_set, instrument_filter from astrowise.raw_dataproducts order by id {}" \
             .format(limit_str)
 
     # Create connection using ssh tunnel with the ldvadmin database