class_docstr: A plugin for the client allowing replay of remote tasks locally
  
  Adds the following methods to the given client:
  
  - ``recreate_error_locally``: main user method for replaying failed tasks
  - ``recreate_task_locally``: main user method for replaying any task
class_docstr_tok: ["A","plugin","for","the","client","allowing","replay","of","remote","tasks","locally","Adds","the","following","methods","to","the","given","client",":","-","``","recreate_error_locally","``",":","main","user","method","for","replaying","failed","tasks","-","``","recreate_task_locally","``",":","main","user","method","for","replaying","any","task"]
code: def scheduler(self):
      return self.client.scheduler
  
file_path: distributed/distributed/recreate_tasks.py
imports: from __future__ import annotations
  import logging
  from dask.core import validate_key
  from distributed.client import Future, futures_of, wait
  from distributed.protocol.serialize import ToPickle
  from distributed.utils import sync
  from distributed.utils_comm import pack_data
label_desc: Use image node_id 2 for calling the ReplayTaskClient obj's underlying member method code with example usage: obj.scheduler() and returns: self