endi_celery.tasks package

Submodules

endi_celery.tasks.accounting_measure_compute module

endi_celery.tasks.accounting_parser module

endi_celery.tasks.csv_import module

endi_celery.tasks.export module

endi_celery.tasks.mail module

endi_celery.tasks.tasks module

endi_celery.tasks.utils module

endi_celery.tasks.utils.check_alive()

Check the redis service is available

endi_celery.tasks.utils.get_job(celery_request, job_model, job_id)

Return the current executed job (in endi’s sens)

Paramètres:

• celery_request (obj) – The current celery request object

• job_model (obj) – The Job model

• job_id (int) – The id of the job

Renvoie:

The current job

Lève:

sqlalchemy.orm.exc.NoResultFound – If the job could not be found

endi_celery.tasks.utils.get_logger(name='')

endi_celery.tasks.utils.get_task(task_id: int) → Task

Retrieve a task

Paramètres:

• celery_request (obj) – The current celery request object

• task_id (int) – The id of the Task object

Renvoie:

The current Task

Lève:

sqlalchemy.orm.exc.NoResultFound – If the Task could not be found

endi_celery.tasks.utils.record_completed(job_model, job_id, **kwargs)

Record job’s completion and set additionnal arguments

endi_celery.tasks.utils.record_failure(job_model, job_id, e=None, **kwargs)

Record a job’s failure

endi_celery.tasks.utils.set_current_user(pyramid_request, user_id)

set a user on the current request

endi_celery.tasks.utils.start_job(celery_request, job_model, job_id) → None

Entry point to launch when starting a job

Paramètres:

• celery_request (obj) – The current celery request object

• job_model (obj) – The Job model

• job_id (int) – The id of the job

Renvoie:

The current job or None

Module contents

endi_celery.tasks.includeme(config)