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)},