sample_progress_state.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

# Buit-ins
import time

# PIP Installs
from celery.task import current, task

def super_long_process(c, max_count):
  """ 
  Use the current module to set a custom state and populate with meta data 
  see for more info http://docs.celeryproject.org/en/latest/userguide/tasks.html#custom-states
  """
  for i in xrange(1,max_count):
    c.update_state(state='PROGRESS',meta={'current':i,'total':max_count})
    time.sleep(4)
    
@celery_app.task(bind=True, ignore_result=True)
def cool_progress_task(self):
  """
  execute a long running task, might no need current, 
  can maybe do it with self. need more investiagtion 
  """
  super_long_process(current, 10000)