code: def job_started_message(self, job, queue):
          
          return '[%s|%s|%s] starting' % (queue._cached_name, job.pk.get(),
                                          job._cached_identifier)
docs: Return the message to log just befre the execution of the job