[Python-modules-commits] [dask.distributed] branch upstream updated (82546bc -> e344b30)

Diane Trout diane at moszumanska.debian.org
Wed Aug 9 23:28:00 UTC 2017


This is an automated email from the git hooks/post-receive script.

diane pushed a change to branch upstream
in repository dask.distributed.

      from  82546bc   Import dask.distributed_1.16.1+ds.1.orig.tar.gz
      adds  e344b30   New upstream version 1.18.0+ds.1

No new revisions were added by this update.

Summary of changes:
 .gitignore                                         |    5 +
 .travis.yml                                        |   81 +-
 MANIFEST.in                                        |    2 +
 appveyor.yml                                       |    3 -
 continuous_integration/setup_conda_environment.cmd |   28 +-
 continuous_integration/travis/install.sh           |   83 ++
 continuous_integration/travis/run_tests.sh         |   35 +
 distributed/__init__.py                            |   14 +-
 distributed/asyncio.py                             |  169 +++
 distributed/batched.py                             |    5 +
 distributed/bokeh/application.py                   |  119 --
 distributed/bokeh/background/server_lifecycle.py   |    4 +-
 distributed/bokeh/components.py                    |    8 +-
 distributed/bokeh/core.py                          |   32 +-
 distributed/bokeh/scheduler.py                     |  737 +++++++++-
 distributed/bokeh/status/__init__.py               |    0
 distributed/bokeh/status/main.py                   |   40 -
 distributed/bokeh/status/templates/index.html      |   74 -
 distributed/bokeh/task_stream.py                   |  113 ++
 distributed/bokeh/tasks/__init__.py                |    0
 distributed/bokeh/tasks/main.py                    |   20 -
 distributed/bokeh/template.html                    |  115 ++
 distributed/bokeh/tests/test_application.py        |   49 -
 distributed/bokeh/tests/test_scheduler_bokeh.py    |  189 ++-
 distributed/bokeh/tests/test_task_stream.py        |   41 +
 distributed/bokeh/tests/test_worker_bokeh.py       |   13 +-
 distributed/bokeh/worker.py                        |   96 +-
 distributed/bokeh/workers/__init__.py              |    0
 distributed/bokeh/workers/main.py                  |   30 -
 distributed/bokeh/workers/templates/index.html     |   74 -
 distributed/cfexecutor.py                          |  168 +++
 distributed/channels.py                            |  300 ----
 distributed/cli/dask_scheduler.py                  |  107 +-
 distributed/cli/dask_worker.py                     |  171 ++-
 distributed/cli/tests/test_cli_utils.py            |   10 +-
 distributed/cli/tests/test_dask_scheduler.py       |  123 +-
 distributed/cli/tests/test_dask_worker.py          |    6 +-
 distributed/cli/tests/test_tls_cli.py              |   60 +
 distributed/cli/utils.py                           |    2 +-
 distributed/client.py                              | 1108 ++++++++++-----
 distributed/collections.py                         |  271 ----
 distributed/comm/__init__.py                       |   18 -
 distributed/comm/addressing.py                     |    4 +-
 distributed/comm/core.py                           |   37 +-
 distributed/comm/inproc.py                         |   29 +-
 distributed/comm/registry.py                       |    4 +-
 distributed/comm/tcp.py                            |  238 +++-
 distributed/comm/tests/test_comms.py               |  346 +++--
 distributed/comm/utils.py                          |   66 +-
 distributed/comm/zmq.py                            |  301 ----
 distributed/comm/zmqimpl.py                        |  239 ----
 distributed/compatibility.py                       |    7 +-
 distributed/config.py                              |  143 +-
 distributed/config.yaml                            |   19 +
 distributed/core.py                                |  108 +-
 distributed/deploy/adaptive.py                     |    2 +-
 distributed/deploy/local.py                        |  137 +-
 distributed/deploy/ssh.py                          |   87 +-
 distributed/deploy/tests/test_adaptive.py          |    5 +-
 distributed/deploy/tests/test_local.py             |  115 +-
 distributed/diagnostics/plugin.py                  |   13 +
 distributed/diagnostics/progress.py                |   77 +-
 distributed/diagnostics/progress_stream.py         |    6 +-
 distributed/diagnostics/progressbar.py             |    4 +-
 distributed/diagnostics/tests/test_plugin.py       |   44 +-
 distributed/diagnostics/tests/test_progress.py     |   37 +-
 .../diagnostics/tests/test_progress_stream.py      |    8 +-
 distributed/hdfs.py                                |   36 +-
 distributed/http/core.py                           |    2 +-
 distributed/joblib.py                              |  108 +-
 distributed/nanny.py                               |  626 +++++----
 distributed/node.py                                |   37 +
 distributed/preloading.py                          |   51 +
 distributed/process.py                             |  273 ++++
 distributed/protocol/__init__.py                   |    9 +-
 distributed/protocol/compression.py                |   74 +-
 distributed/protocol/core.py                       |   21 +-
 distributed/protocol/keras.py                      |   10 +-
 distributed/protocol/numpy.py                      |   81 +-
 distributed/protocol/serialize.py                  |   47 +-
 distributed/protocol/sparse.py                     |   31 +
 distributed/protocol/tests/test_h5py.py            |    4 +-
 distributed/protocol/tests/test_netcdf4.py         |    2 +-
 distributed/protocol/tests/test_numpy.py           |   74 +-
 distributed/protocol/tests/test_protocol.py        |   60 +-
 distributed/protocol/tests/test_protocol_utils.py  |   11 +-
 distributed/protocol/tests/test_serialize.py       |   29 +-
 distributed/protocol/tests/test_sparse.py          |   38 +
 distributed/protocol/utils.py                      |   69 +-
 distributed/queues.py                              |  249 ++++
 distributed/recreate_exceptions.py                 |    2 +-
 distributed/scheduler.py                           |  384 ++++--
 distributed/security.py                            |  146 ++
 distributed/sizeof.py                              |   24 +-
 distributed/stealing.py                            |    5 -
 distributed/submit.py                              |   14 +-
 distributed/system_monitor.py                      |   12 +
 distributed/tests/make_tls_certs.py                |  167 +++
 distributed/tests/py3_test_asyncio.py              |  336 +++++
 distributed/tests/py3_test_client.py               |   39 +-
 distributed/tests/py3_test_utils_tst.py            |   10 +
 distributed/tests/test_as_completed.py             |   39 +-
 distributed/tests/test_asyncio.py                  |    5 +
 distributed/tests/test_asyncprocess.py             |  288 ++++
 distributed/tests/test_channels.py                 |  204 ---
 distributed/tests/test_client.py                   | 1433 +++++++++++++-------
 distributed/tests/test_client_executor.py          |  240 ++++
 distributed/tests/test_collections.py              |  211 +--
 distributed/tests/test_compatibility.py            |    5 +-
 distributed/tests/test_config.py                   |  271 ++++
 distributed/tests/test_core.py                     |  130 +-
 distributed/tests/test_hdfs.py                     |   41 +-
 distributed/tests/test_joblib.py                   |   91 +-
 distributed/tests/test_nanny.py                    |  107 +-
 distributed/tests/test_preload.py                  |   65 +
 distributed/tests/test_publish.py                  |   60 +-
 distributed/tests/test_queues.py                   |  229 ++++
 distributed/tests/test_resources.py                |    4 +-
 distributed/tests/test_scheduler.py                |   92 +-
 distributed/tests/test_security.py                 |  368 +++++
 distributed/tests/test_sizeof.py                   |    7 +
 distributed/tests/test_steal.py                    |   37 +-
 distributed/tests/test_stress.py                   |   15 +-
 distributed/tests/test_system_monitor.py           |   35 +
 distributed/tests/test_threadpoolexecutor.py       |    2 -
 distributed/tests/test_tls_functional.py           |  171 +++
 distributed/tests/test_utils.py                    |  126 +-
 distributed/tests/test_utils_comm.py               |    3 +-
 distributed/tests/test_utils_test.py               |   37 +-
 distributed/tests/test_variable.py                 |  207 +++
 distributed/tests/test_worker.py                   |  259 +++-
 distributed/tests/test_worker_client.py            |  108 +-
 distributed/tests/test_worker_failure.py           |   78 +-
 distributed/tests/tls-ca-cert.pem                  |   78 ++
 distributed/tests/tls-ca-key.pem                   |   28 +
 distributed/tests/tls-cert-chain.pem               |  135 ++
 distributed/tests/tls-cert.pem                     |   57 +
 distributed/tests/tls-key-cert.pem                 |   73 +
 distributed/tests/tls-key.pem                      |   16 +
 distributed/tests/tls-self-signed-cert.pem         |   14 +
 distributed/tests/tls-self-signed-key.pem          |   16 +
 distributed/threadpoolexecutor.py                  |   24 +-
 distributed/utils.py                               |  235 +++-
 distributed/utils_comm.py                          |   37 +-
 distributed/utils_test.py                          |  287 +++-
 distributed/variable.py                            |  207 +++
 distributed/versions.py                            |    6 +-
 distributed/worker.py                              |  447 ++++--
 distributed/worker_client.py                       |  166 +--
 docs/source/adaptive.rst                           |    5 +-
 docs/source/api.rst                                |   79 +-
 docs/source/asynchronous.rst                       |  147 ++
 docs/source/changelog.rst                          |   81 ++
 docs/source/channels.rst                           |  149 --
 docs/source/client.rst                             |   22 +-
 docs/source/communications.rst                     |    8 +-
 docs/source/conf.py                                |    8 +
 docs/source/configuration.rst                      |  176 +++
 docs/source/develop.rst                            |    3 +-
 docs/source/foundations.rst                        |    4 +-
 docs/source/index.rst                              |   22 +-
 docs/source/joblib.rst                             |   14 +
 docs/source/quickstart.rst                         |   14 +-
 docs/source/related-work.rst                       |   33 +-
 docs/source/scheduling-policies.rst                |   27 +
 docs/source/setup.rst                              |   61 +-
 docs/source/tls.rst                                |   98 ++
 requirements.txt                                   |    8 +-
 setup.py                                           |   18 +-
 169 files changed, 12574 insertions(+), 4877 deletions(-)
 create mode 100644 continuous_integration/travis/install.sh
 create mode 100644 continuous_integration/travis/run_tests.sh
 create mode 100644 distributed/asyncio.py
 delete mode 100644 distributed/bokeh/application.py
 delete mode 100644 distributed/bokeh/status/__init__.py
 delete mode 100644 distributed/bokeh/status/main.py
 delete mode 100644 distributed/bokeh/status/templates/index.html
 create mode 100644 distributed/bokeh/task_stream.py
 delete mode 100644 distributed/bokeh/tasks/__init__.py
 delete mode 100644 distributed/bokeh/tasks/main.py
 create mode 100644 distributed/bokeh/template.html
 delete mode 100644 distributed/bokeh/tests/test_application.py
 create mode 100644 distributed/bokeh/tests/test_task_stream.py
 delete mode 100644 distributed/bokeh/workers/__init__.py
 delete mode 100644 distributed/bokeh/workers/main.py
 delete mode 100644 distributed/bokeh/workers/templates/index.html
 create mode 100644 distributed/cfexecutor.py
 delete mode 100644 distributed/channels.py
 create mode 100644 distributed/cli/tests/test_tls_cli.py
 delete mode 100644 distributed/collections.py
 delete mode 100644 distributed/comm/zmq.py
 delete mode 100644 distributed/comm/zmqimpl.py
 create mode 100644 distributed/node.py
 create mode 100644 distributed/preloading.py
 create mode 100644 distributed/process.py
 create mode 100644 distributed/protocol/sparse.py
 create mode 100644 distributed/protocol/tests/test_sparse.py
 create mode 100644 distributed/queues.py
 create mode 100644 distributed/security.py
 create mode 100644 distributed/tests/make_tls_certs.py
 create mode 100644 distributed/tests/py3_test_asyncio.py
 create mode 100644 distributed/tests/py3_test_utils_tst.py
 create mode 100644 distributed/tests/test_asyncio.py
 create mode 100644 distributed/tests/test_asyncprocess.py
 delete mode 100644 distributed/tests/test_channels.py
 create mode 100644 distributed/tests/test_client_executor.py
 create mode 100644 distributed/tests/test_config.py
 create mode 100644 distributed/tests/test_preload.py
 create mode 100644 distributed/tests/test_queues.py
 create mode 100644 distributed/tests/test_security.py
 create mode 100644 distributed/tests/test_tls_functional.py
 create mode 100644 distributed/tests/test_variable.py
 create mode 100644 distributed/tests/tls-ca-cert.pem
 create mode 100644 distributed/tests/tls-ca-key.pem
 create mode 100644 distributed/tests/tls-cert-chain.pem
 create mode 100644 distributed/tests/tls-cert.pem
 create mode 100644 distributed/tests/tls-key-cert.pem
 create mode 100644 distributed/tests/tls-key.pem
 create mode 100644 distributed/tests/tls-self-signed-cert.pem
 create mode 100644 distributed/tests/tls-self-signed-key.pem
 create mode 100644 distributed/variable.py
 create mode 100644 docs/source/asynchronous.rst
 delete mode 100644 docs/source/channels.rst
 create mode 100644 docs/source/configuration.rst
 create mode 100644 docs/source/tls.rst

-- 
Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/python-modules/packages/dask.distributed.git



More information about the Python-modules-commits mailing list