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