seta algumas tasks para a fila load

Author: pitangainnovare

article/tasks.py

@@ -20,7 +20,7 @@
 
 User = get_user_model()
 
-@celery_app.task(bind=True, name=_('Load article data from Article Meta'), timelimit=-1)
+@celery_app.task(bind=True, name=_('Load article data from Article Meta'), timelimit=-1, queue='load')
 def task_load_article_from_article_meta(self, from_date=None, until_date=None, days_to_go_back=None, collection=None, issn=None, force_update=True, user_id=None, username=None):
     user = _get_user(self.request, username=username, user_id=user_id)
 
@@ -91,7 +91,7 @@ def task_load_article_from_article_meta(self, from_date=None, until_date=None, d
     return True
 
 
-@celery_app.task(bind=True, name=_('Load article data from OPAC'), timelimit=-1)
+@celery_app.task(bind=True, name=_('Load article data from OPAC'), timelimit=-1, queue='load')
 def task_load_article_from_opac(self, collection='scl', from_date=None, until_date=None, days_to_go_back=None, page=1, force_update=True, user_id=None, username=None):
     user = _get_user(self.request, username=username, user_id=user_id)
 
@@ -156,7 +156,7 @@ def task_load_article_from_opac(self, collection='scl', from_date=None, until_da
     return True
 
 
-@celery_app.task(bind=True, name=_('Load preprint data from SciELO Preprints'), timelimit=-1)
+@celery_app.task(bind=True, name=_('Load preprint data from SciELO Preprints'), timelimit=-1, queue='load')
 def task_load_preprints_from_preprints_api(self, from_date=None, until_date=None, days_to_go_back=None, force_update=True, user_id=None, username=None):
     user = _get_user(self.request, username=username, user_id=user_id)
 
@@ -206,7 +206,7 @@ def task_load_preprints_from_preprints_api(self, from_date=None, until_date=None
             continue
 
 
-@celery_app.task(bind=True, name=_('Load dataset metadata from Dataverse'), timelimit=-1)
+@celery_app.task(bind=True, name=_('Load dataset metadata from Dataverse'), timelimit=-1, queue='load')
 def task_load_dataset_metadata_from_dataverse(self, from_date=None, until_date=None, days_to_go_back=None, force_update=True, user_id=None, username=None):
     user = _get_user(self.request, username=username, user_id=user_id)
 

journal/tasks.py

@@ -15,7 +15,7 @@
 User = get_user_model()
 
 
-@celery_app.task(bind=True, name=_('Load journal data from Article Meta'))
+@celery_app.task(bind=True, name=_('Load journal data from Article Meta'), queue='load')
 def task_load_journal_data_from_article_meta(self, collections=[], force_update=True, user_id=None, username=None, mode='thrift'):
     user = _get_user(user_id, username)
 

log_manager/tasks.py

@@ -26,7 +26,7 @@
 User = get_user_model()
 
 
-@celery_app.task(bind=True, name=_('Search for log files'))
+@celery_app.task(bind=True, name=_('Search for log files'), queue='load')
 def task_search_log_files(self, collections=[], from_date=None, until_date=None, days_to_go_back=None, user_id=None, username=None):
     """
     Task to search for log files in the directories defined in the CollectionLogDirectory model.
@@ -85,7 +85,7 @@ def _add_log_file(user, collection, root, name, visible_dates):
         )
 
 
-@celery_app.task(bind=True, name=_('Validate log files'), timelimit=-1)
+@celery_app.task(bind=True, name=_('Validate log files'), timelimit=-1, queue='load')
 def task_validate_log_files(self, collections=[], from_date=None, until_date=None, days_to_go_back=None, user_id=None, username=None, ignore_date=False):
     """
     Task to validate log files in the database.
@@ -113,7 +113,7 @@ def task_validate_log_files(self, collections=[], from_date=None, until_date=Non
                 task_validate_log_file.apply_async(args=(log_file.hash, user_id, username))
 
 
-@celery_app.task(bind=True, name=_('Validate log file'), timelimit=-1)
+@celery_app.task(bind=True, name=_('Validate log file'), timelimit=-1, queue='load')
 def task_validate_log_file(self, log_file_hash, user_id=None, username=None):
     """
     Task to validate a specific log file.