a #e @sddlmZddlZejddedZejdddd d d iiej_d d dddddddddddddddddddddddddddddddddddej_ GdddZ ie _ d d!e _ e d"kredS)#)CeleryNDJANGO_SETTINGS_MODULEzwebodm.settingstaskszdjango.conf:settingsZCELERY) namespace retry_policytimeoutg@zworker.tasks.update_nodes_infoF)expiresretry)taskscheduleoptionszworker.tasks.cleanup_projects<zworker.tasks.cleanup_tasksiiz"worker.tasks.cleanup_tmp_directoryz"worker.tasks.process_pending_taskszworker.tasks.check_quotas)zupdate-nodes-infozcleanup-projectsz cleanup-taskszcleanup-tmp-directoryzprocess-pending-tasksz check-quotasc@s&eZdZdddZddZddZdS) MockAsyncResultNcCsB||_|dur.|dkrd|_q>tj||_n||_|tj|<dS)NZbogus)celery_task_idresultrresultsget)selfrrr/webodm/worker/celery.py__init__CszMockAsyncResult.__init__cCs|jSNrrrrrrNszMockAsyncResult.getcCs |jduSrrrrrrreadyQszMockAsyncResult.ready)N)__name__ __module__ __qualname__rrrrrrrrBs rcCs t||Sr)r)ZctirrrrUr$__main__)celeryrosenviron setdefaultappconfig_from_objectconfZ result_backend_transport_options beat_schedulerrsetr startrrrrsd       4