def METHOD_NAME(
    self,
    path,
    mode="rb",
    block_size=None,
    autocommit=True,
    cache_options=None,
    **kwargs,
):
    if self.worker:
        return self.fs.METHOD_NAME(
            path,
            mode=mode,
            block_size=block_size,
            autocommit=autocommit,
            cache_options=cache_options,
            **kwargs,
        )
    else:
        return DaskFile(
            fs=self,
            path=path,
            mode=mode,
            block_size=block_size,
            autocommit=autocommit,
            cache_options=cache_options,
            **kwargs,
        )