def METHOD_NAME(redis_huey, task_factory: TaskFactory):
    @redis_huey.task()
    @write_required(script=True)
    def _execute_fn(job_id):
        execute_by_job_id(job_id, task_factory)
    return _execute_fn