--spec-file .yml example

[morikplay]

Hello all,
Is there an example yaml file for scheduler, nanny and workers which can be provided as input to dask_spec.py. Based on what i understand, the following .yml for scheduler gives out a weak reference error.

env

• windows server 2019
• python 3.10.1
• dask 2022.2.1
• asyncssh 2.9.0

trial.yml

cls: distributed.Scheduler
opts:
  port: 8786
  dashboard: true
  dashboard_address: :8787

command executed:

<prompt>> python -m distributed.cli.dask_spec <ip> --spec-file trial.yml

Error

C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\distributed\cli\dask_spec.py:45: DeprecationWarning: There is no current event loop
  asyncio.get_event_loop().run_until_complete(run())
arg length is  1
Sending  1  args =  tcp://10.61.61.35:8786
distributed.http.proxy - INFO - To route to workers diagnostics web server please install jupyter-server-proxy: python -m pip install jupyter-server-proxy
Traceback (most recent call last):
  File "C:\Users\maulik\miniconda3\envs\mls\lib\runpy.py", line 196, in _run_module_as_main
    return _run_code(code, main_globals, None,
  File "C:\Users\maulik\miniconda3\envs\mls\lib\runpy.py", line 86, in _run_code
    exec(code, run_globals)
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\distributed\cli\dask_spec.py", line 49, in <module>
    main()
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\click\core.py", line 1128, in __call__
    return self.main(*args, **kwargs)
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\click\core.py", line 1053, in main
    rv = self.invoke(ctx)
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\click\core.py", line 1395, in invoke
    return ctx.invoke(self.callback, **ctx.params)
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\click\core.py", line 754, in invoke
    return __callback(*args, **kwargs)
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\distributed\cli\dask_spec.py", line 45, in main
    asyncio.get_event_loop().run_until_complete(run())
  File "C:\Users\maulik\miniconda3\envs\mls\lib\asyncio\base_events.py", line 641, in run_until_complete
    return future.result()
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\distributed\cli\dask_spec.py", line 37, in run
    servers = await run_spec(_spec, args[0]) # Maulik 03/03/22
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\distributed\deploy\spec.py", line 637, in run_spec
    workers[k] = cls(*args, **d.get("opts", {}))
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\distributed\scheduler.py", line 3977, in __init__
    super().__init__(
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\distributed\scheduler.py", line 2101, in __init__
    super().__init__(**kwargs)  # type: ignore
  File "C:\Users\maulik\miniconda3\envs\mls\lib\site-packages\distributed\core.py", line 203, in __init__
    ref = weakref.ref(self.io_loop)
TypeError: cannot create weak reference to 'str' object