Class ClientExecutor

Declaration

Documentation

Methods

• ▷ def __init__(self, client, **kwargs)

  source link
• ▶ def map(self, fn, *iterables, **kwargs)

  Returns an iterator equivalent to ``map(fn, *iterables)``.

  source link

  Parameters

  • fn : A callable that will take as many arguments as there are
    

    passed iterables.

  • iterables : One iterable for each parameter to *fn*.
  • timeout : The maximum number of seconds to wait. If None, then there
    

    is no limit on the wait time.

  • chunksize : ignored.

  Returns

  • ``map(fn, *iterables)`` but the calls may

  Raises

  • TimeoutError: If the entire result iterator could not be generated
    

    before the given timeout.

  • Exception: If ``fn(*args)`` raises for any values.
• ▶ def shutdown(self, wait=True)

  Clean-up the resources associated with the Executor.

  source link

  It is safe to call this method several times. Otherwise, no other
  methods can be called after this one.

  Parameters

  • wait : If True then shutdown will not return until all running
    

    futures have finished executing.  If False then all running
    futures are cancelled immediately.

• ▶ def submit(self, fn, *args, **kwargs)

  Submits a callable to be executed with the given arguments.

  source link

  Schedules the callable to be executed as ``fn(*args, **kwargs)``
  and returns a Future instance representing the execution of the callable.

  Returns

  • A Future representing the given call.

Reexports

• Imported in distributed.client.

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