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());
                     }
                 }