diff --git a/dags/oaebu_workflows/onix_workflow/sql/book_metrics_country.sql.jinja2 b/dags/oaebu_workflows/onix_workflow/sql/book_metrics_country.sql.jinja2 index c5bd251c..f2ebc78a 100644 --- a/dags/oaebu_workflows/onix_workflow/sql/book_metrics_country.sql.jinja2 +++ b/dags/oaebu_workflows/onix_workflow/sql/book_metrics_country.sql.jinja2 @@ -21,7 +21,8 @@ countries as ( alpha2, iso_name, wikipedia_name, - jstor_name + jstor_name, + muse_name FROM `{{ country_table_id }}` ), @@ -51,7 +52,8 @@ month_country as ( iso_name as country_name, iso_name as country_iso_name, wikipedia_name as country_wikipedia_name, - jstor_name as country_jstor_name + jstor_name as country_jstor_name, + muse_name as country_muse_name FROM months CROSS JOIN countries ) diff --git a/dags/oaebu_workflows/sql/shmp_pilot/book_metrics_country_join_muse_country_pilot.sql b/dags/oaebu_workflows/sql/shmp_pilot/book_metrics_country_join_muse_country_pilot.sql index d927b446..be949dab 100644 --- a/dags/oaebu_workflows/sql/shmp_pilot/book_metrics_country_join_muse_country_pilot.sql +++ b/dags/oaebu_workflows/sql/shmp_pilot/book_metrics_country_join_muse_country_pilot.sql @@ -1,3 +1,3 @@ LEFT JOIN muse_month_country as muse_country_pilot ON month_country.ISBN13 = muse_country_pilot.ISBN13 AND month_country.month = muse_country_pilot.month -AND (month_country.country_iso_name = muse_country_pilot.country_name OR month_country.country_wikipedia_name = muse_country_pilot.country_name) +AND month_country.country_muse_name = muse_country_pilot.country_name