Rename ProcessorState method

restatedev · Nov 19, 2024 · 9f6d162 · 9f6d162
1 parent b1c89f4
commit 9f6d162
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/crates/worker/src/partition_processor_manager/mod.rs b/crates/worker/src/partition_processor_manager/mod.rs
@@ -698,7 +698,7 @@ impl PartitionProcessorManager {
             }
         };
 
-        if !processor_state.should_publish_snapshot() {
+        if !processor_state.should_publish_snapshots() {
             let _ = sender.send(Err(SnapshotError::InvalidState(partition_id)));
             return;
         }

diff --git a/crates/worker/src/partition_processor_manager/processor_state.rs b/crates/worker/src/partition_processor_manager/processor_state.rs
@@ -355,7 +355,7 @@ impl ProcessorState {
     /// The Partition Processor is in a state in which it is acceptable to create and publish
     /// snapshots. Since we don't want newer snapshots to move backwards in applied LSN, the current
     /// implementation checks whether the processor is fully caught up with the log.
-    pub fn should_publish_snapshot(&self) -> bool {
+    pub fn should_publish_snapshots(&self) -> bool {
         match self {
             ProcessorState::Started {
                 processor: Some(started_processor),
-Original file line number
+Diff line change
@@ Expand Up / @@ -698,7 +698,7 @@ impl PartitionProcessorManager { @@
                 }
             };
-            if !processor_state.should_publish_snapshot() {
+            if !processor_state.should_publish_snapshots() {
                 let _ = sender.send(Err(SnapshotError::InvalidState(partition_id)));
                 return;
             }
@@ Expand Down @@