endi_celery package¶
Subpackages¶
- endi_celery.parsers package
- endi_celery.schedulers package
- endi_celery.tasks package
Submodules¶
endi_celery.conf module¶
endi_celery.exception module¶
endi_celery.hacks module¶
endi_celery.interfaces module¶
endi_celery.locks module¶
endi_celery.mail module¶
endi_celery.models module¶
Celery tasks related models
- class endi_celery.models.BulkFileGenerationJob(**kwargs)¶
Bases :
Job
A single job (re)generating several endi.models.files.File
- created_at¶
- error_messages¶
- id¶
- jobid¶
- label = 'Génération de fichiers en lot'¶
- messages¶
- results_list¶
- status¶
- todict()¶
- type_¶
- updated_at¶
- class endi_celery.models.CsvImportJob(**kwargs)¶
Bases :
Job
Store csv importation job status
- created_at¶
- error_messages¶
- id¶
- in_error_csv¶
- is_not_void_str(value)¶
Return True if the string contains datas
- jobid¶
- label = 'Import de données'¶
- messages¶
- status¶
- todict()¶
- type_¶
- unhandled_datas_csv¶
- updated_at¶
- class endi_celery.models.FileGenerationJob(**kwargs)¶
Bases :
Job
- created_at¶
- error_messages¶
- filename¶
- force_download¶
- id¶
- jobid¶
- label = 'Génération de fichier'¶
- status¶
- todict()¶
- type_¶
- updated_at¶
- class endi_celery.models.Job(**kwargs)¶
Bases :
Base
,PersistentACLMixin
Base job model, used to communicate a job’s status between the main pyramid app and celery asynchronous tasks
- created_at¶
- id¶
- jobid¶
- label = 'Tâche générique'¶
- set_owner(login)¶
Set the job owner’s acls
- status¶
- timeout()¶
Check if this element should be timeouted
- todict()¶
- type_¶
- updated_at¶
- class endi_celery.models.MailHistory(**kwargs)¶
Bases :
Base
Stores the history of mail sent by our application to any company
- company¶
- company_id¶
- property filename¶
- filepath¶
- id¶
- md5sum¶
- send_at¶
- class endi_celery.models.MailingJob(**kwargs)¶
Bases :
Job
Store mailing job status
- created_at¶
- error_messages¶
- id¶
- jobid¶
- label = 'Envoi de mail'¶
- messages¶
- status¶
- todict()¶
- type_¶
- updated_at¶
- endi_celery.models.check_if_mail_sent(filedatas, company_id)¶
Check if the given file has already been sent :param str filedatas: The content of a file :param int company_id: The id of a company