VER: Release 0.33.1

Author: threecgreen

CHANGELOG.md

@@ -1,12 +1,20 @@
 # Changelog
 
+## 0.33.1 - TBD
+
+### Enhancements
+- Upgraded DBN version to 0.41.0:
+  - Added `interval` method to `RType` and `Schema` to get the duration for subsampled
+    schemas like `Ohlcv1H` and `Cbbo1S`
+  - Changed the default value for `channel_id` to be `u8::MAX` in `MboMsg` and `u16::MAX`
+    elsewhere since 0 is a valid channel ID
+
 ## 0.33.0 - 2025-08-19
 
 ### Enhancements
 - Upgraded DBN version to 0.40.0:
   - Added `DbnVersion` new type
 
-
 ### Breaking changes
 - Removed `bill_id` field from `BatchJob` struct
 - Breaking changes from DBN:

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "databento"
 authors = ["Databento <support@databento.com>"]
-version = "0.33.0"
+version = "0.33.1"
 edition = "2021"
 repository = "https://github.com/databento/databento-rs"
 description = "Official Databento client library"
@@ -31,7 +31,7 @@ historical = [
 live = ["dep:hex", "dep:sha2", "tokio/net"]
 
 [dependencies]
-dbn = { version = "0.40.0", features = ["async", "serde"] }
+dbn = { version = "0.41.0", features = ["async", "serde"] }
 
 async-compression = { version = "0.4", features = ["tokio", "zstd"], optional = true }
 # Async stream trait

src/historical.rs

@@ -27,24 +27,23 @@ pub enum HistoricalGateway {
     Bo1,
 }
 
-/// A **half**-closed date interval with an inclusive start date and an exclusive end
+/// A **half**-closed date interval with an inclusive UTC start date and an exclusive UTC end
 /// date.
 #[derive(Clone, Debug, PartialEq, Eq)]
 pub struct DateRange {
-    /// The start date (inclusive).
+    /// The inclusive UTC start date.
     start: time::Date,
-    /// The end date (exclusive).
+    /// The exclusive UTC end date.
     end: time::Date,
 }
 
-/// A **half**-closed datetime interval with an inclusive start time and an exclusive
-/// end time.
+/// A **half**-closed datetime interval with an inclusive start and an exclusive end.
 #[derive(Clone, Debug, PartialEq, Eq, Deserialize)]
 pub struct DateTimeRange {
-    /// The start date time (inclusive).
+    /// The inclusive start.
     #[serde(deserialize_with = "deserialize_date_time")]
     start: time::OffsetDateTime,
-    /// The end date time (exclusive).
+    /// The exclusive end.
     #[serde(deserialize_with = "deserialize_date_time")]
     end: time::OffsetDateTime,
 }

src/historical/batch.rs

@@ -240,7 +240,7 @@ pub struct SubmitJobParams {
     pub symbols: Symbols,
     /// The data record schema.
     pub schema: Schema,
-    /// The date time request range.
+    /// The request range with an inclusive start and an exclusive end.
     /// Filters on `ts_recv` if it exists in the schema, otherwise `ts_event`.
     #[builder(setter(into))]
     pub date_time_range: DateTimeRange,
@@ -311,10 +311,10 @@ pub struct BatchJob {
     pub stype_out: SType,
     /// The data record schema.
     pub schema: Schema,
-    /// The start of the request time range (inclusive).
+    /// The inclusive start of the request range.
     #[serde(deserialize_with = "deserialize_date_time")]
     pub start: OffsetDateTime,
-    /// The end of the request time range (exclusive).
+    /// The exclusive end of the request range.
     #[serde(deserialize_with = "deserialize_date_time")]
     pub end: OffsetDateTime,
     /// The maximum number of records to return.

src/historical/metadata.rs

@@ -255,7 +255,8 @@ pub struct GetDatasetConditionParams {
     /// The dataset code.
     #[builder(setter(transform = |dataset: impl ToString| dataset.to_string()))]
     pub dataset: String,
-    /// The optional filter by UTC date range.
+    /// The UTC date request range with an inclusive start date and an inclusive end date.
+    /// If `None` then will return all available dates.
     #[builder(default, setter(transform = |dr: impl Into<DateRange>| Some(dr.into())))]
     pub date_range: Option<DateRange>,
 }
@@ -278,10 +279,10 @@ pub struct DatasetConditionDetail {
 /// The available range for a dataset.
 #[derive(Debug, Clone, PartialEq, Eq, Deserialize)]
 pub struct DatasetRange {
-    /// The start of the available range.
+    /// The inclusive UTC start timestamp of the available range.
     #[serde(deserialize_with = "deserialize_date_time")]
     pub start: time::OffsetDateTime,
-    /// The end of the available range (exclusive).
+    /// The exclusive UTC end timestamp of the available range.
     #[serde(deserialize_with = "deserialize_date_time")]
     pub end: time::OffsetDateTime,
     /// The available ranges for each available schema in the dataset.
@@ -306,7 +307,7 @@ pub struct GetQueryParams {
     pub symbols: Symbols,
     /// The data record schema.
     pub schema: Schema,
-    /// The request time range.
+    /// The request range with an inclusive start and an exclusive end.
     #[builder(setter(into))]
     pub date_time_range: DateTimeRange,
     /// The symbology type of the input `symbols`. Defaults to

src/historical/symbology.rs

@@ -71,7 +71,7 @@ pub struct ResolveParams {
     /// [`InstrumentId`](dbn::enums::SType::InstrumentId).
     #[builder(default = SType::InstrumentId)]
     pub stype_out: SType,
-    /// The date range of the resolution.
+    /// The UTC date range with an inclusive start and an exclusive end.
     #[builder(setter(into))]
     pub date_range: DateRange,
 }

src/historical/timeseries.rs

@@ -165,7 +165,7 @@ pub struct GetRangeParams {
     pub symbols: Symbols,
     /// The data record schema.
     pub schema: Schema,
-    /// The date time request range.
+    /// The request range with an inclusive start and an exclusive end.
     /// Filters on `ts_recv` if it exists in the schema, otherwise `ts_event`.
     #[builder(setter(into))]
     pub date_time_range: DateTimeRange,
@@ -202,7 +202,7 @@ pub struct GetRangeToFileParams {
     pub symbols: Symbols,
     /// The data record schema.
     pub schema: Schema,
-    /// The date time request range.
+    /// The request range with an inclusive start and an exclusive end.
     /// Filters on `ts_recv` if it exists in the schema, otherwise `ts_event`.
     #[builder(setter(into))]
     pub date_time_range: DateTimeRange,