tasks: add domain to tasks
1 files changed, 2 insertions(+), 2 deletions(-) M meteo_scraper/task.py
M meteo_scraper/task.py +2 -2
@@ 12,7 12,7 @@ from meteo_scraper.ecmwf_scraper import CONFIG = reader('meteo.cfg') -@task +@task(domain='meteo') def scrap_ecmwf_hres(task): tsa = apimaker( {'db': {'uri': str(task.engine.url)}, @@ 24,7 24,7 @@ def scrap_ecmwf_hres(task): hres_ecmwfdata_to_refinery(tsa) -@task +@task(domain='meteo') def scrap_ecmwf_ens(task): tsa = apimaker( {'db': {'uri': str(task.engine.url)},