code: def job_started(self, job, queue):
          
          job.hmset(start=str(datetime.utcnow()), status=STATUSES.RUNNING)
          job.tries.hincrby(1)
          self.log(self.job_started_message(job, queue))
          if hasattr(job, 'on_started'):
              job.on_started(queue)
docs: Called just before the execution of the job