Merge pull request #242 from dora-rs/release-v0.2.2

Bump to `v0.2.2` version

Cargo.toml

@@ -24,28 +24,28 @@ members = [
 
 [workspace.package]
 # Make sure to also bump `apis/node/python/__init__.py` version.
-version = "0.2.1"
+version = "0.2.2"
 description = "`dora` goal is to be a low latency, composable, and distributed data flow."
 documentation = "https://dora.carsmos.ai/dora/"
 license = "Apache-2.0"
 
 [workspace.dependencies]
-dora-node-api = { version = "0.2.1", path = "apis/rust/node", default-features = false }
-dora-operator-api = { version = "0.2.1", path = "apis/rust/operator", default-features = false }
-dora-operator-api-macros = { version = "0.2.1", path = "apis/rust/operator/macros" }
-dora-operator-api-types = { version = "0.2.1", path = "apis/rust/operator/types" }
-dora-operator-api-python = { version = "0.2.1", path = "apis/python/operator" }
-dora-operator-api-c = { version = "0.2.1", path = "apis/c/operator" }
-dora-node-api-c = { version = "0.2.1", path = "apis/c/node" }
-dora-core = { version = "0.2.1", path = "libraries/core" }
-dora-tracing = { version = "0.2.1", path = "libraries/extensions/telemetry/tracing" }
-dora-metrics = { version = "0.2.1", path = "libraries/extensions/telemetry/metrics" }
-dora-download = { version = "0.2.1", path = "libraries/extensions/download" }
-shared-memory-server = { version = "0.2.1", path = "libraries/shared-memory-server" }
-communication-layer-request-reply = { version = "0.2.1", path = "libraries/communication-layer/request-reply" }
-dora-message = { version = "0.2.1", path = "libraries/message" }
-dora-runtime = { version = "0.2.1", path = "binaries/runtime" }
-dora-daemon = { version = "0.2.1", path = "binaries/daemon" }
+dora-node-api = { version = "0.2.2", path = "apis/rust/node", default-features = false }
+dora-operator-api = { version = "0.2.2", path = "apis/rust/operator", default-features = false }
+dora-operator-api-macros = { version = "0.2.2", path = "apis/rust/operator/macros" }
+dora-operator-api-types = { version = "0.2.2", path = "apis/rust/operator/types" }
+dora-operator-api-python = { version = "0.2.2", path = "apis/python/operator" }
+dora-operator-api-c = { version = "0.2.2", path = "apis/c/operator" }
+dora-node-api-c = { version = "0.2.2", path = "apis/c/node" }
+dora-core = { version = "0.2.2", path = "libraries/core" }
+dora-tracing = { version = "0.2.2", path = "libraries/extensions/telemetry/tracing" }
+dora-metrics = { version = "0.2.2", path = "libraries/extensions/telemetry/metrics" }
+dora-download = { version = "0.2.2", path = "libraries/extensions/download" }
+shared-memory-server = { version = "0.2.2", path = "libraries/shared-memory-server" }
+communication-layer-request-reply = { version = "0.2.2", path = "libraries/communication-layer/request-reply" }
+dora-message = { version = "0.2.2", path = "libraries/message" }
+dora-runtime = { version = "0.2.2", path = "binaries/runtime" }
+dora-daemon = { version = "0.2.2", path = "binaries/daemon" }
 
 [package]
 name = "dora-examples"

Changelog.md

@@ -1,5 +1,25 @@
 # Changelog
 
+## v0.2.2 (2023-04-01)
+
+### Features
+
+* Make queue length configurable through the dataflow file by @phil-opp in https://github.com/dora-rs/dora/pull/231
+* Hot reloading Python Operator  by @haixuanTao in https://github.com/dora-rs/dora/pull/239
+* Synchronize node and operator start by @phil-opp in https://github.com/dora-rs/dora/pull/236
+* Add opentelemetry capability at runtime instead of compile time by @haixuanTao in https://github.com/dora-rs/dora/pull/234
+
+### Others
+
+* Wait on events and messages simultaneously to prevent queue buildup by @phil-opp in https://github.com/dora-rs/dora/pull/235
+* Fix looping in daemon listener loop by @phil-opp in https://github.com/dora-rs/dora/pull/244
+* Validate shell command as source and url source by @haixuanTao in https://github.com/dora-rs/dora/pull/243
+* Push error into the `init_done` channel for debugging context by @haixuanTao in https://github.com/dora-rs/dora/pull/238
+* Option communication config by @haixuanTao in https://github.com/dora-rs/dora/pull/241
+* Validate yaml when reading by @haixuanTao in https://github.com/dora-rs/dora/pull/237
+
+**Full Changelog**: https://github.com/dora-rs/dora/compare/v0.2.1...v0.2.2
+
 ## v0.2.1 (2023-03-22)
 
 ### Features

apis/python/node/dora/__init__.py

@@ -3,7 +3,7 @@
 from .dora import *
 
 __author__ = "Dora-rs Authors"
-__version__ = "0.2.1"
+__version__ = "0.2.2"
 
 
 class DoraStatus(Enum):

binaries/daemon/src/spawn.rs

@@ -5,15 +5,13 @@ use crate::{
 use dora_core::{
     config::NodeRunConfig,
     daemon_messages::{DaemonCommunicationConfig, DataflowId, NodeConfig, RuntimeConfig},
-    descriptor::{resolve_path, source_is_url, OperatorSource, ResolvedNode},
+    descriptor::{resolve_path, source_is_url, OperatorSource, ResolvedNode, SHELL_SOURCE},
 };
 use dora_download::download_file;
 use eyre::WrapErr;
 use std::{env::consts::EXE_EXTENSION, path::Path, process::Stdio};
 use tokio::sync::mpsc;
 
-const SHELL_SOURCE: &str = "shell";
-
 pub async fn spawn_node(
     dataflow_id: DataflowId,
     working_dir: &Path,

libraries/core/src/descriptor/mod.rs

@@ -15,11 +15,13 @@ pub use visualize::collect_dora_timers;
 
 mod validate;
 mod visualize;
+pub const SHELL_SOURCE: &str = "shell";
 
 #[derive(Debug, Serialize, Deserialize)]
 #[serde(deny_unknown_fields)]
 pub struct Descriptor {
     // see https://github.com/dtolnay/serde-yaml/issues/298
+    #[serde(default)]
     #[serde(with = "serde_yaml::with::singleton_map")]
     pub communication: Option<CommunicationConfig>,
     pub nodes: Vec<Node>,