def METHOD_NAME(self):
    if _in_worker():
        self.worker = True
        if self.fs is None:
            self.fs = filesystem(
                self.target_protocol, **(self.target_options or {})
            )
    else:
        self.worker = False
        self.client = _get_client(self.client)
        self.rfs = dask.delayed(self)