code: def registerFileSystem(client, fs, root, prefix):
      ok = False
      msg = ""
      if client is None:
          ok, msg = cio.registerFileSystemCaller(fs, root, prefix)
          msg = msg.decode("utf-8")
          if not ok:
              return ok, msg, fs
      else:
          dask_futures = []
          i = 0
          for worker in list(client.scheduler_info()["workers"]):
              # REMARK: pure argument is neccesary for this case to ensure each
              # dask worker executes registerFileSystemCaller
              dask_futures.append(
                  client.submit(
                      cio.registerFileSystemCaller,
                      fs,
                      root,
                      prefix,
                      pure=False,
                      workers=[worker],
                  )
              )
              i = i + 1
          for connection in dask_futures:
              ok, msg = connection.result()
              msg = msg.decode("utf-8")
              if not ok:
                  msg = msg + " with dask worker " + str(worker)
                  return ok, msg, fs
      return ok, msg, fs
  
file_path: blazingsql/pyblazing/pyblazing/apiv2/filesystem.py
imports: from collections import OrderedDict
  import cio
  from pyblazing.apiv2 import S3EncryptionType
label_desc: Use image node_id 1 for calling a global function with example usage: registerFileSystem(client, fs, root, prefix) and returns: ok,  msg,  fs, ok,  msg,  fs, ok,  msg,  fs