Skip to content

Commit 10c1034

Browse files
author
Michael Rosenberg
committed
Remove check that checkpoint extensions are empty
1 parent b7089b1 commit 10c1034

File tree

2 files changed

+2
-12
lines changed

2 files changed

+2
-12
lines changed

crates/generic_log_worker/src/ctlog.rs

Lines changed: 1 addition & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ use crate::{
2424
CacheRead, CacheWrite, LockBackend, LookupKey, ObjectBackend, SequenceMetadata,
2525
SequencerConfig,
2626
};
27-
use anyhow::{anyhow, bail, ensure};
27+
use anyhow::{anyhow, bail};
2828
use futures_util::future::try_join_all;
2929
use log::{debug, error, info, trace, warn};
3030
use serde::{Deserialize, Serialize};
@@ -319,11 +319,6 @@ impl SequenceState {
319319
now_millis(),
320320
&stored_checkpoint,
321321
)?;
322-
// We don't use extension lines for any of our checkpoints
323-
ensure!(
324-
c.extension().is_empty(),
325-
"unexpected extension in DO checkpoint"
326-
);
327322

328323
let timestamp = match timestamp {
329324
Some(timestamp) => timestamp,
@@ -344,11 +339,6 @@ impl SequenceState {
344339
std::str::from_utf8(&stored_checkpoint)?
345340
);
346341
let (c1, _) = tlog_tiles::open_checkpoint(&config.origin, &verifiers, now_millis(), &sth)?;
347-
// We don't use extension lines for any of our checkpoints
348-
ensure!(
349-
c1.extension().is_empty(),
350-
"unexpected extension in R2 checkpoint"
351-
);
352342

353343
match (Ord::cmp(&c1.size(), &c.size()), c1.hash() == c.hash()) {
354344
(Ordering::Equal, false) => {

crates/generic_log_worker/src/sequencer_do.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ use crate::{
1515
use futures_util::future::join_all;
1616
use log::{info, warn};
1717
use prometheus::{Registry, TextEncoder};
18-
use tlog_tiles::{CheckpointSigner, LogEntry, PendingLogEntry, RecordProof, TlogError};
18+
use tlog_tiles::{CheckpointSigner, LogEntry, PendingLogEntry, RecordProof};
1919
use tokio::sync::Mutex;
2020
use worker::{Bucket, Error as WorkerError, Request, Response, State};
2121

0 commit comments

Comments
 (0)