Skip to content

Commit 28430ee

Browse files
Merge pull request #277 from TimelyDataflow/v0.10
v0.10 release
2 parents 9430c46 + cbdfd16 commit 28430ee

File tree

5 files changed

+26
-28
lines changed

5 files changed

+26
-28
lines changed

CHANGELOG.md

+4-2
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,13 @@
22

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

5-
## Unreleased
5+
## 0.10.0
66

77
### Added
88

9-
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).
9+
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).
10+
11+
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).
1012

1113
## 0.9.0
1214

bytes/Cargo.toml

+5-7
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,13 @@
11
[package]
22
name = "timely_bytes"
3-
version = "0.9.0"
3+
version = "0.10.0"
44
authors = ["Frank McSherry <[email protected]>"]
55
edition = "2018"
66

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

9-
documentation = "https://frankmcsherry.github.com/timely-dataflow"
10-
homepage = "https://github.com/frankmcsherry/timely-dataflow"
11-
repository = "https://github.com/frankmcsherry/timely-dataflow.git"
9+
documentation = "https://docs.rs/timely/"
10+
homepage = "https://github.com/TimelyDataflow/timely-dataflow"
11+
repository = "https://github.com/TimelyDataflow/timely-dataflow.git"
1212
keywords = ["timely", "dataflow", "bytes"]
13-
license = "MIT"
14-
15-
[dependencies]
13+
license = "MIT"

communication/Cargo.toml

+7-6
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,15 @@
11
[package]
22
name = "timely_communication"
3-
version = "0.9.0"
3+
version = "0.10.0"
44
authors = ["Frank McSherry <[email protected]>"]
55
description = "Communication layer for timely dataflow"
66
edition = "2018"
77

88
# These URLs point to more information about the repository
9-
documentation = "https://frankmcsherry.github.com/timely-dataflow"
10-
homepage = "https://github.com/frankmcsherry/timely-dataflow"
11-
repository = "https://github.com/frankmcsherry/timely-dataflow.git"
9+
10+
documentation = "https://docs.rs/timely/"
11+
homepage = "https://github.com/TimelyDataflow/timely-dataflow"
12+
repository = "https://github.com/TimelyDataflow/timely-dataflow.git"
1213
keywords = ["timely", "dataflow"]
1314
license = "MIT"
1415

@@ -22,5 +23,5 @@ serde_derive = "1.0"
2223
serde = "1.0"
2324
abomonation = "0.7"
2425
abomonation_derive = "0.4"
25-
timely_bytes = { path = "../bytes", version = "0.9" }
26-
timely_logging = { path = "../logging", version = "0.9" }
26+
timely_bytes = { path = "../bytes", version = "0.10" }
27+
timely_logging = { path = "../logging", version = "0.10" }

logging/Cargo.toml

+5-8
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,13 @@
11
[package]
22
name = "timely_logging"
3-
version = "0.9.0"
3+
version = "0.10.0"
44
authors = ["Frank McSherry <[email protected]>"]
55
edition = "2018"
66

77
description = "Common timely logging infrastructure"
88

9-
documentation = "https://frankmcsherry.github.com/timely-dataflow"
10-
homepage = "https://github.com/frankmcsherry/timely-dataflow"
11-
repository = "https://github.com/frankmcsherry/timely-dataflow.git"
9+
documentation = "https://docs.rs/timely/"
10+
homepage = "https://github.com/TimelyDataflow/timely-dataflow"
11+
repository = "https://github.com/TimelyDataflow/timely-dataflow.git"
1212
keywords = ["timely", "dataflow", "logging"]
13-
license = "MIT"
14-
15-
16-
[dependencies]
13+
license = "MIT"

timely/Cargo.toml

+5-5
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
[package]
22

33
name = "timely"
4-
version = "0.9.0"
4+
version = "0.10.0"
55
authors = ["Frank McSherry <[email protected]>"]
6-
readme = "README.md"
6+
readme = "../README.md"
77
edition = "2018"
88

99
description = "A low-latency data-parallel dataflow system in Rust"
@@ -23,9 +23,9 @@ serde = "1.0"
2323
serde_derive = "1.0"
2424
abomonation = "0.7"
2525
abomonation_derive = "0.3"
26-
timely_bytes = { path = "../bytes", version = "0.9" }
27-
timely_logging = { path = "../logging", version = "0.9" }
28-
timely_communication = { path = "../communication", version = "0.9" }
26+
timely_bytes = { path = "../bytes", version = "0.10" }
27+
timely_logging = { path = "../logging", version = "0.10" }
28+
timely_communication = { path = "../communication", version = "0.10" }
2929

3030
[dev-dependencies]
3131
timely_sort="0.1.6"

0 commit comments

Comments
 (0)