Code

Optimize transitions#4451

Code

Merged

jakirkham merged 22 commits intodask:masterdask/distributed:masterfrom jakirkham:opt_transitionjakirkham/distributed:opt_transitionCopy head branch name to clipboardFeb 2, 2021

+174-57

Commits

Commits on Jan 29, 2021

• Annotate keys & new

  jakirkham

  committed
  63c60d0

• Combine recommendations annotation with others

  jakirkham

  committed
  a9648a0

• Annotate dependents & dependencies

  jakirkham

  committed
  ead596f

• Annotate start & finish

  jakirkham

  committed
  6e5bcab

• Create empty dict for recommendations once

  Show description for 23b34ba
  jakirkham

  committed
  23b34ba

• Use .get(...) to retrieve TaskState

  jakirkham

  committed
  20e0dfb

• Assign start, finish to a variable

  jakirkham

  committed
  dbeb0cd

• Just use .get(...) to retrieve transition func

  Show description for 9c8b820
  jakirkham

  committed
  9c8b820

• Annotate a & b

  jakirkham

  committed
  2907628

• Use .get(...) to get key from a

  Show description for 5d7bd6e
  jakirkham

  committed
  5d7bd6e

• Just update recommendations with a & b

  jakirkham

  committed
  b26e527

• Drop unneeded KeyError handling

  Show description for b8e09fe
  jakirkham

  committed
  b8e09fe

• Annotate finish2

  jakirkham

  committed
  43a09bf

• Replace generator with simple for-loop

  Show description for f47b9b6
  jakirkham

  committed
  f47b9b6

• Bind tuple results to typed variable

  Show description for a8282dd
  jakirkham

  committed
  a8282dd

• Collect list of messages for clients and workers

  jakirkham

  committed
  3d7ad9c

• Extend BatchedSend's send to take many msgs

  jakirkham

  committed
  6b62ef1

• Add send_all method and use in transition

  Show description for 6f46e72
  jakirkham

  committed
  6f46e72

• Deliver all messages to batched send

  jakirkham

  committed
  e2c849f

• Refactor out private _transition function

  jakirkham

  committed
  8a39818

• Send all messages after processing all transitions

  jakirkham

  committed
  6da1d47

• declare ALL_TASK_STATES a set

  jakirkham

  committed
  cdcfcf2