From db1e8b12c358001983370d01549021c03b1e61bb Mon Sep 17 00:00:00 2001
From: Frank McSherry <fmcsherry@me.com>
Date: Wed, 18 Dec 2024 09:33:23 -0500
Subject: [PATCH] Update to track timely changes (#554)

---
 src/trace/implementations/merge_batcher.rs | 5 ++---
 src/trace/mod.rs                           | 3 +--
 2 files changed, 3 insertions(+), 5 deletions(-)

diff --git a/src/trace/implementations/merge_batcher.rs b/src/trace/implementations/merge_batcher.rs
index 90e13508e..159aee4a1 100644
--- a/src/trace/implementations/merge_batcher.rs
+++ b/src/trace/implementations/merge_batcher.rs
@@ -3,7 +3,6 @@
 use std::collections::VecDeque;
 use std::marker::PhantomData;
 
-use timely::logging::WorkerIdentifier;
 use timely::logging_core::Logger;
 use timely::progress::frontier::AntichainRef;
 use timely::progress::{frontier::Antichain, Timestamp};
@@ -32,7 +31,7 @@ where
     /// Thing to accept data, merge chains, and talk to the builder.
     merger: M,
     /// Logger for size accounting.
-    logger: Option<Logger<DifferentialEvent, WorkerIdentifier>>,
+    logger: Option<Logger<DifferentialEvent>>,
     /// Timely operator ID.
     operator_id: usize,
     /// Current lower frontier, we sealed up to here.
@@ -52,7 +51,7 @@ where
     type Time = M::Time;
     type Output = M::Chunk;
 
-    fn new(logger: Option<Logger<DifferentialEvent, WorkerIdentifier>>, operator_id: usize) -> Self {
+    fn new(logger: Option<Logger<DifferentialEvent>>, operator_id: usize) -> Self {
         Self {
             logger,
             operator_id,
diff --git a/src/trace/mod.rs b/src/trace/mod.rs
index 7ea9064fa..e06183faf 100644
--- a/src/trace/mod.rs
+++ b/src/trace/mod.rs
@@ -12,7 +12,6 @@ pub mod description;
 pub mod implementations;
 pub mod wrappers;
 
-use timely::logging::WorkerIdentifier;
 use timely::logging_core::Logger;
 use timely::progress::{Antichain, frontier::AntichainRef};
 use timely::progress::Timestamp;
@@ -310,7 +309,7 @@ pub trait Batcher {
     /// Times at which batches are formed.
     type Time: Timestamp;
     /// Allocates a new empty batcher.
-    fn new(logger: Option<Logger<DifferentialEvent, WorkerIdentifier>>, operator_id: usize) -> Self;
+    fn new(logger: Option<Logger<DifferentialEvent>>, operator_id: usize) -> Self;
     /// Adds an unordered container of elements to the batcher.
     fn push_container(&mut self, batch: &mut Self::Input);
     /// Returns all updates not greater or equal to an element of `upper`.