{"push_id":2499195508,"size":67,"distinct_size":67,"ref":"refs/heads/patch-10","head":"15790744dfb523db3be499d835469088a5f72616","before":"e101568450a53c1f21a588516f8f0629bf13b289","commits":[{"sha":"278f3c9822f48b793f1bce9643d312ec691bafd2","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Avoid restarting workers when nanny waits (#1793)\n\n* Ensure nanny behaves when waiting for scheduler\r\n\r\n* downgrade client-scheduler connection lost warning\r\n\r\n* Update last tick when starting periodic callbacks\r\n\r\nThis stops the tick warning from firing in between creating the worker\r\nand starting the tick callback","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/278f3c9822f48b793f1bce9643d312ec691bafd2"},{"sha":"627fdbb536a19e1fc14c39c26502724e2036292c","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Local cluster async (#1798)\n\n* Replace start= keyword in LocalCluster with asynchronous=\r\n\r\nAlso define LocalCluster.__await__\r\n\r\nThis copies the pattern set out in Client\r\n\r\n    cluster = yield LocalCluster(asynchronous=True)\r\n\r\n* add async with protocols to LocalCluster","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/627fdbb536a19e1fc14c39c26502724e2036292c"},{"sha":"13b9fc3d875fc0586ccf8cd0a8621dd9cfc44fdf","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Add n= keyword to retire_workers (#1800)\n\nThis allows you to retire a specific number of workers","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/13b9fc3d875fc0586ccf8cd0a8621dd9cfc44fdf"},{"sha":"3dba77bfc56ecfc7ab2833a39e379706bb8dde71","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Support minimum, maximum, wait_count keywords in Adaptive (#1797)\n\n* Support asyncio coroutines in gen_test\r\n\r\n* Add minimum and maximum keywords to adaptive\r\n\r\nThis allows for bounded scaling\r\n\r\n* Add wait_count to adaptive\r\n\r\nThis makes the cluster wait a few beats between thinking that a worker\r\nshould maybe be removed and actually removing it.  This helps to avoid\r\nunnecessary churn.","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/3dba77bfc56ecfc7ab2833a39e379706bb8dde71"},{"sha":"6cc529979fe1e7398d55badb639a49b310b454e8","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Keep logs in scheduler and worker even if silenced (#1803)\n\nThis silences the global StreamHandler rather than the loggers entirely.\r\n\r\nFixes https://github.com/dask/distributed/issues/1771","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/6cc529979fe1e7398d55badb639a49b310b454e8"},{"sha":"52860fd9a8a9c3df0da8abbfc08513beb3fb6a9c","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Add parse datetime utility function","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/52860fd9a8a9c3df0da8abbfc08513beb3fb6a9c"},{"sha":"0a0c5fafe1546d8b6be346033327b24c56908509","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Use string time deltas everywhere\n\nPreviously when taking time-delta inputs we usually took numbers that\nrepresented either seconds or milliseconds, depending on if we were\nusing system python or tornado/bokeh commands.  Now we normalize\neverything to strings or timedelta objects and parse them.\n\nThis is clearer and more explicit.\n\nWe maintain backwards compatibility by supporting a default= keyword\nto parse_timedelta that lets us choose a default unit.","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/0a0c5fafe1546d8b6be346033327b24c56908509"},{"sha":"57599e86d01905a4b78c2540c9ed5d09a176fa63","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Ensure the client is quiet if scheduler leaves (#1806)\n\nWe still print out a basic warning, but previously we were dumping\r\nlarge stack traces every few seconds.","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/57599e86d01905a4b78c2540c9ed5d09a176fa63"},{"sha":"cea29960de89918e0ad0eb44a310374cb7828c15","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Check idle/saturated in extra cases (#1801)\n\n* Check idle/saturated in extra cases\r\n\r\nPreviously there were two cases where we decreased occupancy but didn't\r\ncheck idle/saturated.\r\n\r\n1.  Long running tasks\r\n2.  Stealing\r\n\r\nNow we do.\r\n\r\n* Avoid errors when nanny is terminated while starting\r\n\r\nThis was causing errors in\r\n\r\n    py.test distributed/tests/test_stress.py::test_stress_creation_and_deletion\r\n\r\n* Avoid placing closed workers in idle in check_idle_saturated\r\n\r\nThis used to raise exceptions in the following test:\r\n\r\ndistributed/tests/test_stress.py::test_stress_creation_and_deletion\r\n\r\nBecause stealing code would call check_idle_saturated on workers\r\neven if they had recently been removed.  This caused a mismatch of\r\noccupancy and some other errors.\r\n\r\nTo resolve this efficiently we now keep a ``WorkerState.status``\r\nattribute and check it in check_idle_saturated\r\n\r\n* reduce uncertainty on test_learn_occupancy\r\n\r\n* Tolerate time delays in test_inproc_comm_closed_explicit_2","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/cea29960de89918e0ad0eb44a310374cb7828c15"},{"sha":"1df988002fb03658eb95bf128aa98038cfdc42c1","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Make diagnostics link in client configurable (#1810)","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/1df988002fb03658eb95bf128aa98038cfdc42c1"},{"sha":"be7d0715edc4a76cee3e8adb151e5473f10823bf","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"bump version to 1.21.2","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/be7d0715edc4a76cee3e8adb151e5473f10823bf"},{"sha":"21e67411a759fe9108b20a4a92020b8f628ba20a","author":{"name":"Sven Kreiss","email":"b1c1d8736f20db3fb6c1c66bb1455ed43909f0d8@svenkreiss.com"},"message":"overwrite option for remote python (#1812)","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/21e67411a759fe9108b20a4a92020b8f628ba20a"},{"sha":"2e02f3efdcb79f2c9524d38695cf8b9d447ddca1","author":{"name":"Brett Naul","email":"e0ec734d24d7a0c41f6b595f050092e8d709623d@gmail.com"},"message":"Add percentage to profile plot (#1817)","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/2e02f3efdcb79f2c9524d38695cf8b9d447ddca1"},{"sha":"b5bf64192d130d26b3ea8651c675741b3727f0a0","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Support calling compute within worker_client (#1814)\n\nPreviously we failed when calling secede twice.","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/b5bf64192d130d26b3ea8651c675741b3727f0a0"},{"sha":"021582672d66610702b9b84ae02ee44c5ddb4c8a","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Scale adaptive based on total_occupancy (#1807)","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/021582672d66610702b9b84ae02ee44c5ddb4c8a"},{"sha":"3bf3f4526920db962b4807f9739d27ad54640840","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Add worker time to live in Scheduler (#1811)\n\nThis allows the scheduler to define a time period within which a worker\r\nshould heartbeat or else it will be removed from the scheduler's\r\nunderstanding of the cluster.\r\n\r\nThis is configurable either by passing the parameter directly to the\r\nScheduler, or by adding an entry like the following to the config.yaml\r\nfile\r\n\r\n    worker-ttl: 60s","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/3bf3f4526920db962b4807f9739d27ad54640840"},{"sha":"79da5a0c21d1ea1a4e2b508ffae8cda6944966ce","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Fix bug in recreate_error when dependencies are dropped (#1815)\n\n* Fix bug in recreate_error when dependencies are dropped\r\n\r\n* fix test_tick_logging","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/79da5a0c21d1ea1a4e2b508ffae8cda6944966ce"},{"sha":"3eb811948286e01d3a45e0f29ae68e86105e018e","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Fixup tests and support Python 2 for Tornado 5.0 (#1818)\n\n* Remove read_into Tornado optimization for Python 2\r\n\r\nPython 2 doesn't handle bytearray in the same way as Python 3.\r\nRather than address this problem we're just going to not support this\r\noptimization for now.  It is only relevant on high bandwidth networks,\r\nand we'd like to encourage people to move to Python 3.\r\n\r\nFixes https://github.com/dask/distributed/issues/1816\r\n\r\n* allow travis to use tornado 5.0 everywhere\r\n\r\n* use default channel in travis-ci\r\n\r\n* Fix some tornado failures\r\n\r\n* silence disconnection messages when not running\r\n\r\n* handle finicky tests\r\n\r\n* reduce timeout in ttl test\r\n\r\n* fix test_race\r\n\r\n* tmp\r\n\r\n* avoid reporting errors when shutting down","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/3eb811948286e01d3a45e0f29ae68e86105e018e"},{"sha":"6569ac82653fd4e4527c66020b796655daeacddc","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"Add cluster superclass and improve adaptivity (#1813)","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/6569ac82653fd4e4527c66020b796655daeacddc"},{"sha":"33f12684e58fc01d82bea5adbaa57bb319e99b0d","author":{"name":"Matthew Rocklin","email":"25bf21f79a16dfce44c401d023ce25dcf1907fde@gmail.com"},"message":"bump version to 1.21.3","distinct":true,"url":"https://api.github.com/repos/rbubley/distributed/commits/33f12684e58fc01d82bea5adbaa57bb319e99b0d"}]}
{"actor":{"display_login":"rbubley"}}