diff --git a/catalog/dags/providers/provider_api_scripts/jamendo.py b/catalog/dags/providers/provider_api_scripts/jamendo.py index b1be8632d4d..5243bf9589b 100644 --- a/catalog/dags/providers/provider_api_scripts/jamendo.py +++ b/catalog/dags/providers/provider_api_scripts/jamendo.py @@ -258,8 +258,8 @@ def create_postingestion_tasks(): """ select_query = ( - "WHERE provider='jamendo' AND meta_data->>'audiodownload_allowed'" - " = 'False'" + f"WHERE provider='{prov.JAMENDO_DEFAULT_PROVIDER}' " + "AND meta_data->>'audiodownload_allowed' = 'False'" ) @task_group(group_id="delete_records_with_downloads_disabled")