Class MultiProgress

Declaration

Documentation

See Progress for most details.  This only adds a function ``func=``
that splits keys.  This defaults to ``key_split`` which aligns with naming
conventions chosen in the dask project (tuples, hyphens, etc..)

State
-----
keys: dict
    Maps group name to set of not-yet-complete keys for that group
all_keys: dict
    Maps group name to set of all keys for that group

Examples

>>> split = lambda s: s.split('-')[0]
>>> p = MultiProgress(['y-2'], func=split)  # doctest: +SKIP
>>> p.keys   # doctest: +SKIP
{'x': {'x-1', 'x-2', 'x-3'},
 'y': {'y-1', 'y-2'}}

Methods

• ▶ def __init__(self, keys, scheduler=None, func=key_split, minimum=0, dt=0.1, complete=False) override

  source link

  This method overrides distributed.diagnostics.progress.Progress.__init__.

• ▶ def transition(self, key, start, finish, *args, **kwargs) override

  inherited doc Run whenever a task changes state

  source link

  This method overrides distributed.diagnostics.progress.Progress.transition.

  Parameters

  • key : string
  • start : string
    

    Start state of the transition.
    One of released, waiting, processing, memory, error.

  • finish : string
    

    Final state of the transition.

  • *args, **kwargs : More options passed when transitioning
    

    This may include worker ID, compute time, etc.

Inherited methods

• Methods inherited from distributed.diagnostics.progress.Progress:
  restart, stop
• Methods inherited from distributed.diagnostics.plugin.SchedulerPlugin:
  add_client, add_worker, remove_client, remove_worker, update_graph

Reexports

• Imported in distributed.diagnostics.progressbar.
• Imported in distributed.diagnostics.tests.test_progress.

Generated by nedoc v0.9 at 2020-12-29 14:05