VER: Release 0.32.0

Author: threecgreen

CHANGELOG.md

@@ -1,5 +1,16 @@
 # Changelog
 
+## 0.32.0 - 2025-08-12
+
+### Enhancements
+- Upgraded DBN version to 0.39.1:
+  - Added `PUBLISHER_SPECIFIC` flag
+  - Improved JSON encoding performance
+  - Added a `Default` implementation for `SecurityUpdateAction`
+
+### Breaking changes
+- Removed unused `Received` variant from `JobState` enum
+
 ## 0.31.0 - 2025-07-30
 
 ### Enhancements

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "databento"
 authors = ["Databento <support@databento.com>"]
-version = "0.31.0"
+version = "0.32.0"
 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.39.0", features = ["async", "serde"] }
+dbn = { version = "0.39.1", features = ["async", "serde"] }
 
 async-compression = { version = "0.4", features = ["tokio", "zstd"], optional = true }
 # Async stream trait
@@ -52,11 +52,11 @@ tracing = "0.1"
 typed-builder = "0.21"
 
 [dev-dependencies]
-anyhow = "1.0.98"
+anyhow = "1.0.99"
 async-compression = { version = "0.4", features = ["tokio", "zstd"] }
-clap = { version = "4.5.40", features = ["derive"] }
+clap = { version = "4.5.44", features = ["derive"] }
 rstest = "0.26.1"
 tempfile = "3.20.0"
-tokio = { version = "1.45", features = ["full"] }
+tokio = { version = "1.47", features = ["full"] }
 tracing-subscriber = "0.3.19"
 wiremock = "0.6"

src/historical/batch.rs

@@ -218,8 +218,6 @@ pub enum Delivery {
 /// The state of a batch job.
 #[derive(Clone, Copy, Debug, PartialEq, Eq)]
 pub enum JobState {
-    /// The job has been received (the initial state).
-    Received,
     /// The job has been queued for processing.
     Queued,
     /// The job has begun processing.
@@ -374,7 +372,7 @@ pub struct BatchJob {
 /// get a builder type with all the preset defaults.
 #[derive(Debug, Clone, Default, TypedBuilder, PartialEq, Eq)]
 pub struct ListJobsParams {
-    /// The optional filter for job states.
+    /// The optional filter for job states. If `None`, defaults to all except `Expired`.
     #[builder(default, setter(strip_option))]
     pub states: Option<Vec<JobState>>,
     /// The optional filter for timestamp submitted (will not include jobs prior to
@@ -497,7 +495,6 @@ impl JobState {
     /// Converts the enum to its `str` representation.
     pub const fn as_str(&self) -> &'static str {
         match self {
-            JobState::Received => "received",
             JobState::Queued => "queued",
             JobState::Processing => "processing",
             JobState::Done => "done",
@@ -517,7 +514,6 @@ impl FromStr for JobState {
 
     fn from_str(s: &str) -> Result<Self, Self::Err> {
         match s {
-            "received" => Ok(JobState::Received),
             "queued" => Ok(JobState::Queued),
             "processing" => Ok(JobState::Processing),
             "done" => Ok(JobState::Done),

src/historical/client.rs

@@ -90,22 +90,22 @@ impl Client {
     }
 
     /// Returns the batch subclient.
-    pub fn batch(&mut self) -> BatchClient {
+    pub fn batch(&mut self) -> BatchClient<'_> {
         BatchClient { inner: self }
     }
 
     /// Returns the metadata subclient.
-    pub fn metadata(&mut self) -> MetadataClient {
+    pub fn metadata(&mut self) -> MetadataClient<'_> {
         MetadataClient { inner: self }
     }
 
     /// Returns the symbology subclient.
-    pub fn symbology(&mut self) -> SymbologyClient {
+    pub fn symbology(&mut self) -> SymbologyClient<'_> {
         SymbologyClient { inner: self }
     }
 
     /// Returns the timeseries subclient.
-    pub fn timeseries(&mut self) -> TimeseriesClient {
+    pub fn timeseries(&mut self) -> TimeseriesClient<'_> {
         TimeseriesClient { inner: self }
     }
 

src/live/client.rs

@@ -279,7 +279,7 @@ impl Client {
     /// This method is cancel safe. It can be used within a [`tokio::select!`] statement
     /// without the potential for corrupting the input stream.
     #[instrument(parent = &self.span, level = "debug", skip_all)]
-    pub async fn next_record(&mut self) -> crate::Result<Option<RecordRef>> {
+    pub async fn next_record(&mut self) -> crate::Result<Option<RecordRef<'_>>> {
         if !self.fsm.has_decoded_metadata() {
             return Err(crate::Error::BadArgument {
                 param_name: "self".to_owned(),