Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

v0.10 release #277

Merged
merged 1 commit into from Jul 9, 2019
Merged

v0.10 release #277

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
6 changes: 4 additions & 2 deletions CHANGELOG.md
View file
Open in desktop
Expand Up @@ -2,11 +2,13 @@

All notable changes to this project will be documented in this file.

## Unreleased
## 0.10.0

### Added

A `Worker` now has a `step_or_park(Option<Duration>)` method, which instructs the worker to take a step and gives it permission to part the worker thread for at most the supplied timeout if there is no work to perform. A value of `None` implies no timeout (unboundedly parked) whereas a value of `Some(0)` should return immediately. The communication layers are implemented to awaken workers if they receive new communications, and workers should hand out copies of their `Thread` if they want other threads to wake them for other reasons (e.g. queues from threads external to timely).
A `Worker` now has a `step_or_park(Option<Duration>)` method, which instructs the worker to take a step and gives it permission to park the worker thread for at most the supplied timeout if there is no work to perform. A value of `None` implies no timeout (unboundedly parked) whereas a value of `Some(0)` should return immediately. The communication layers are implemented to awaken workers if they receive new communications, and workers should hand out copies of their `Thread` if they want other threads to wake them for other reasons (e.g. queues from threads external to timely).

Communication `WorkerGuards` expose their underlying join handles to allow the main thread or others to unpark worker threads that may be parked (for example, after pushing new data into a queue shared with the worker).

## 0.9.0

Expand Down
12 changes: 5 additions & 7 deletions bytes/Cargo.toml
View file
Open in desktop
@@ -1,15 +1,13 @@
[package]
name = "timely_bytes"
version = "0.9.0"
version = "0.10.0"
authors = ["Frank McSherry <fmcsherry@me.com>"]
edition = "2018"

description = "Disjoint mutable byte slices from a common allocation"

documentation = "https://frankmcsherry.github.com/timely-dataflow"
homepage = "https://github.com/frankmcsherry/timely-dataflow"
repository = "https://github.com/frankmcsherry/timely-dataflow.git"
documentation = "https://docs.rs/timely/"
homepage = "https://github.com/TimelyDataflow/timely-dataflow"
repository = "https://github.com/TimelyDataflow/timely-dataflow.git"
keywords = ["timely", "dataflow", "bytes"]
license = "MIT"

[dependencies]
license = "MIT"
13 changes: 7 additions & 6 deletions communication/Cargo.toml
View file
Open in desktop
@@ -1,14 +1,15 @@
[package]
name = "timely_communication"
version = "0.9.0"
version = "0.10.0"
authors = ["Frank McSherry <fmcsherry@me.com>"]
description = "Communication layer for timely dataflow"
edition = "2018"

# These URLs point to more information about the repository
documentation = "https://frankmcsherry.github.com/timely-dataflow"
homepage = "https://github.com/frankmcsherry/timely-dataflow"
repository = "https://github.com/frankmcsherry/timely-dataflow.git"

documentation = "https://docs.rs/timely/"
homepage = "https://github.com/TimelyDataflow/timely-dataflow"
repository = "https://github.com/TimelyDataflow/timely-dataflow.git"
keywords = ["timely", "dataflow"]
license = "MIT"

Expand All @@ -22,5 +23,5 @@ serde_derive = "1.0"
serde = "1.0"
abomonation = "0.7"
abomonation_derive = "0.4"
timely_bytes = { path = "../bytes", version = "0.9" }
timely_logging = { path = "../logging", version = "0.9" }
timely_bytes = { path = "../bytes", version = "0.10" }
timely_logging = { path = "../logging", version = "0.10" }
13 changes: 5 additions & 8 deletions logging/Cargo.toml
View file
Open in desktop
@@ -1,16 +1,13 @@
[package]
name = "timely_logging"
version = "0.9.0"
version = "0.10.0"
authors = ["Frank McSherry <fmcsherry@me.com>"]
edition = "2018"

description = "Common timely logging infrastructure"

documentation = "https://frankmcsherry.github.com/timely-dataflow"
homepage = "https://github.com/frankmcsherry/timely-dataflow"
repository = "https://github.com/frankmcsherry/timely-dataflow.git"
documentation = "https://docs.rs/timely/"
homepage = "https://github.com/TimelyDataflow/timely-dataflow"
repository = "https://github.com/TimelyDataflow/timely-dataflow.git"
keywords = ["timely", "dataflow", "logging"]
license = "MIT"


[dependencies]
license = "MIT"
10 changes: 5 additions & 5 deletions timely/Cargo.toml
View file
Open in desktop
@@ -1,9 +1,9 @@
[package]

name = "timely"
version = "0.9.0"
version = "0.10.0"
authors = ["Frank McSherry <fmcsherry@me.com>"]
readme = "README.md"
readme = "../README.md"
edition = "2018"

description = "A low-latency data-parallel dataflow system in Rust"
Expand All @@ -23,9 +23,9 @@ serde = "1.0"
serde_derive = "1.0"
abomonation = "0.7"
abomonation_derive = "0.3"
timely_bytes = { path = "../bytes", version = "0.9" }
timely_logging = { path = "../logging", version = "0.9" }
timely_communication = { path = "../communication", version = "0.9" }
timely_bytes = { path = "../bytes", version = "0.10" }
timely_logging = { path = "../logging", version = "0.10" }
timely_communication = { path = "../communication", version = "0.10" }

[dev-dependencies]
timely_sort="0.1.6"
Expand Down