From 754de853f36aa44c0317c7a792278f3b12f91c0a Mon Sep 17 00:00:00 2001
From: Joel Shepherd <shepherd@amazon.com>
Date: Wed, 14 Oct 2026 19:29:47 +0000
Subject: [PATCH] fix(storage-cassandra): use millisecond stream labels via
 shared helper (introduced in 9f43d03)

---
 crates/storage-cassandra/src/create_table.rs | 2 +-
 crates/storage-cassandra/src/update_table.rs | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/crates/storage-cassandra/src/create_table.rs b/crates/storage-cassandra/src/create_table.rs
index 391e0b82..814ba003 100644
--- a/crates/storage-cassandra/src/create_table.rs
+++ b/crates/storage-cassandra/src/create_table.rs
@@ -26,7 +26,7 @@ impl CassandraEngine {
         account_keyspace: &str,
         table_id: &str,
     ) -> Result<String, StorageError> {
-        let label = chrono::Utc::now().format("%Y-%m-%dT%H:%M:%S").to_string();
+        let label = extenddb_storage::util::new_stream_label();
         let catalog_keyspace = self.catalog_keyspace();
         let now_ms = chrono::Utc::now().timestamp_millis();
 
diff --git a/crates/storage-cassandra/src/update_table.rs b/crates/storage-cassandra/src/update_table.rs
index d4adc197..4a20b861 100644
--- a/crates/storage-cassandra/src/update_table.rs
+++ b/crates/storage-cassandra/src/update_table.rs
@@ -193,7 +193,7 @@ impl CassandraEngine {
                     });
                     if !has_label {
                         needs_label_restore = true;
-                        let label = chrono::Utc::now().format("%Y-%m-%dT%H:%M:%S").to_string();
+                        let label = extenddb_storage::util::new_stream_label();
                         add_update!("stream_label", label.as_str());
                     }
                 }