Browse Source

Add `Default` to serde descriptor to remove the need of the `communication` keyword

Bump version to `v0.2.2-rc-2`
tags/v0.2.2^2
haixuanTao 2 years ago
parent
commit
fea136d6dc
4 changed files with 47 additions and 46 deletions
  1. +28
    -28
      Cargo.lock
  2. +17
    -17
      Cargo.toml
  3. +1
    -1
      apis/python/node/dora/__init__.py
  4. +1
    -0
      libraries/core/src/descriptor/mod.rs

+ 28
- 28
Cargo.lock View File

@@ -250,7 +250,7 @@ checksum = "8c3c1a368f70d6cf7302d78f8f7093da241fb8e8807c05cc9e51a125895a6d5b"


[[package]] [[package]]
name = "benchmark-example-node" name = "benchmark-example-node"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-node-api", "dora-node-api",
"eyre", "eyre",
@@ -263,7 +263,7 @@ dependencies = [


[[package]] [[package]]
name = "benchmark-example-sink" name = "benchmark-example-sink"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-node-api", "dora-node-api",
"eyre", "eyre",
@@ -513,7 +513,7 @@ dependencies = [


[[package]] [[package]]
name = "communication-layer-pub-sub" name = "communication-layer-pub-sub"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"flume", "flume",
"zenoh", "zenoh",
@@ -521,7 +521,7 @@ dependencies = [


[[package]] [[package]]
name = "communication-layer-request-reply" name = "communication-layer-request-reply"
version = "0.2.2"
version = "0.2.2-rc-2"


[[package]] [[package]]
name = "concurrent-queue" name = "concurrent-queue"
@@ -817,7 +817,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-cli" name = "dora-cli"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"atty", "atty",
"clap 4.0.3", "clap 4.0.3",
@@ -841,7 +841,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-coordinator" name = "dora-coordinator"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"ctrlc", "ctrlc",
"dora-core", "dora-core",
@@ -864,7 +864,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-core" name = "dora-core"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-message", "dora-message",
"eyre", "eyre",
@@ -880,7 +880,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-daemon" name = "dora-daemon"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"async-trait", "async-trait",
"bincode", "bincode",
@@ -906,7 +906,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-download" name = "dora-download"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"eyre", "eyre",
"reqwest", "reqwest",
@@ -931,7 +931,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-message" name = "dora-message"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"capnp", "capnp",
"capnpc", "capnpc",
@@ -941,7 +941,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-metrics" name = "dora-metrics"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"futures", "futures",
"opentelemetry 0.17.0", "opentelemetry 0.17.0",
@@ -952,7 +952,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-node-api" name = "dora-node-api"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"bincode", "bincode",
"capnp", "capnp",
@@ -974,7 +974,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-node-api-c" name = "dora-node-api-c"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-node-api", "dora-node-api",
"eyre", "eyre",
@@ -984,7 +984,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-node-api-cxx" name = "dora-node-api-cxx"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"cxx", "cxx",
"cxx-build", "cxx-build",
@@ -994,7 +994,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-node-api-python" name = "dora-node-api-python"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-node-api", "dora-node-api",
"dora-operator-api-python", "dora-operator-api-python",
@@ -1007,7 +1007,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-operator-api" name = "dora-operator-api"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-operator-api-macros", "dora-operator-api-macros",
"dora-operator-api-types", "dora-operator-api-types",
@@ -1015,14 +1015,14 @@ dependencies = [


[[package]] [[package]]
name = "dora-operator-api-c" name = "dora-operator-api-c"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-operator-api-types", "dora-operator-api-types",
] ]


[[package]] [[package]]
name = "dora-operator-api-cxx" name = "dora-operator-api-cxx"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"cxx", "cxx",
"cxx-build", "cxx-build",
@@ -1031,7 +1031,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-operator-api-macros" name = "dora-operator-api-macros"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
@@ -1040,7 +1040,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-operator-api-python" name = "dora-operator-api-python"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-node-api", "dora-node-api",
"eyre", "eyre",
@@ -1051,14 +1051,14 @@ dependencies = [


[[package]] [[package]]
name = "dora-operator-api-types" name = "dora-operator-api-types"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"safer-ffi", "safer-ffi",
] ]


[[package]] [[package]]
name = "dora-runtime" name = "dora-runtime"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"clap 4.0.3", "clap 4.0.3",
"dora-core", "dora-core",
@@ -1086,7 +1086,7 @@ dependencies = [


[[package]] [[package]]
name = "dora-tracing" name = "dora-tracing"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"eyre", "eyre",
"opentelemetry 0.18.0", "opentelemetry 0.18.0",
@@ -3097,7 +3097,7 @@ dependencies = [


[[package]] [[package]]
name = "rust-dataflow-example-node" name = "rust-dataflow-example-node"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-node-api", "dora-node-api",
"eyre", "eyre",
@@ -3108,14 +3108,14 @@ dependencies = [


[[package]] [[package]]
name = "rust-dataflow-example-operator" name = "rust-dataflow-example-operator"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-operator-api", "dora-operator-api",
] ]


[[package]] [[package]]
name = "rust-dataflow-example-sink" name = "rust-dataflow-example-sink"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"dora-node-api", "dora-node-api",
"eyre", "eyre",
@@ -3400,7 +3400,7 @@ dependencies = [


[[package]] [[package]]
name = "shared-memory-server" name = "shared-memory-server"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"bincode", "bincode",
"eyre", "eyre",
@@ -4804,7 +4804,7 @@ dependencies = [


[[package]] [[package]]
name = "zenoh-logger" name = "zenoh-logger"
version = "0.2.2"
version = "0.2.2-rc-2"
dependencies = [ dependencies = [
"zenoh", "zenoh",
] ]


+ 17
- 17
Cargo.toml View File

@@ -24,28 +24,28 @@ members = [


[workspace.package] [workspace.package]
# Make sure to also bump `apis/node/python/__init__.py` version. # Make sure to also bump `apis/node/python/__init__.py` version.
version = "0.2.2"
version = "0.2.2-rc-2"
description = "`dora` goal is to be a low latency, composable, and distributed data flow." description = "`dora` goal is to be a low latency, composable, and distributed data flow."
documentation = "https://dora.carsmos.ai/dora/" documentation = "https://dora.carsmos.ai/dora/"
license = "Apache-2.0" license = "Apache-2.0"


[workspace.dependencies] [workspace.dependencies]
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" }
dora-node-api = { version = "0.2.2-rc-2", path = "apis/rust/node", default-features = false }
dora-operator-api = { version = "0.2.2-rc-2", path = "apis/rust/operator", default-features = false }
dora-operator-api-macros = { version = "0.2.2-rc-2", path = "apis/rust/operator/macros" }
dora-operator-api-types = { version = "0.2.2-rc-2", path = "apis/rust/operator/types" }
dora-operator-api-python = { version = "0.2.2-rc-2", path = "apis/python/operator" }
dora-operator-api-c = { version = "0.2.2-rc-2", path = "apis/c/operator" }
dora-node-api-c = { version = "0.2.2-rc-2", path = "apis/c/node" }
dora-core = { version = "0.2.2-rc-2", path = "libraries/core" }
dora-tracing = { version = "0.2.2-rc-2", path = "libraries/extensions/telemetry/tracing" }
dora-metrics = { version = "0.2.2-rc-2", path = "libraries/extensions/telemetry/metrics" }
dora-download = { version = "0.2.2-rc-2", path = "libraries/extensions/download" }
shared-memory-server = { version = "0.2.2-rc-2", path = "libraries/shared-memory-server" }
communication-layer-request-reply = { version = "0.2.2-rc-2", path = "libraries/communication-layer/request-reply" }
dora-message = { version = "0.2.2-rc-2", path = "libraries/message" }
dora-runtime = { version = "0.2.2-rc-2", path = "binaries/runtime" }
dora-daemon = { version = "0.2.2-rc-2", path = "binaries/daemon" }


[package] [package]
name = "dora-examples" name = "dora-examples"


+ 1
- 1
apis/python/node/dora/__init__.py View File

@@ -3,7 +3,7 @@ from enum import Enum
from .dora import * from .dora import *


__author__ = "Dora-rs Authors" __author__ = "Dora-rs Authors"
__version__ = "0.2.2"
__version__ = "0.2.2-rc-2"




class DoraStatus(Enum): class DoraStatus(Enum):


+ 1
- 0
libraries/core/src/descriptor/mod.rs View File

@@ -21,6 +21,7 @@ pub const SHELL_SOURCE: &str = "shell";
#[serde(deny_unknown_fields)] #[serde(deny_unknown_fields)]
pub struct Descriptor { pub struct Descriptor {
// see https://github.com/dtolnay/serde-yaml/issues/298 // see https://github.com/dtolnay/serde-yaml/issues/298
#[serde(default)]
#[serde(with = "serde_yaml::with::singleton_map")] #[serde(with = "serde_yaml::with::singleton_map")]
pub communication: Option<CommunicationConfig>, pub communication: Option<CommunicationConfig>,
pub nodes: Vec<Node>, pub nodes: Vec<Node>,


Loading…
Cancel
Save