code: def process(self: Task, total: int) -> object:
      for i in range(total):
          self.update_state(
              state="PROGRESS", meta={"current": i + 1, "total": total}
          )
          time.sleep(1)
  
      return {"current": total, "total": total}
  
imports: import time
  from celery import shared_task
  from celery import Task
label_desc: Use image node_id 3 for calling a global function with example usage: process(total) and returns: dict