docs: def execute_job(self, job):
          # type: (Job) -> dict
          """Execute job given by the task queue.
  
          :param job: job
          :type job: Job
          :return: task result
          :rtype: dict
          """
          try:
              return execute_job(job)
  
          except KillWorkerException:
              self._app.logger.info("Stopping Gearman worker on demand flag set.")
              self.stop_worker()
  
          except Exception as e:
              return self.handle_exception(e, job.path)