diff --git a/engine/packages/pegboard/src/keys/actor.rs b/engine/packages/pegboard/src/keys/actor.rs index b564ce0e45..3c0a29a163 100644 --- a/engine/packages/pegboard/src/keys/actor.rs +++ b/engine/packages/pegboard/src/keys/actor.rs @@ -63,17 +63,13 @@ impl<'de> TupleUnpack<'de> for CreateTsKey { #[derive(Debug)] pub struct WorkflowIdKey { - actor_id: Id, + pub actor_id: Id, } impl WorkflowIdKey { pub fn new(actor_id: Id) -> Self { WorkflowIdKey { actor_id } } - - pub fn actor_id(&self) -> Id { - self.actor_id - } } impl FormalKey for WorkflowIdKey { diff --git a/engine/packages/pegboard/src/workflows/actor_runner_name_selector_backfill.rs b/engine/packages/pegboard/src/workflows/actor_runner_name_selector_backfill.rs index 8a39bf40d8..49629e9f7c 100644 --- a/engine/packages/pegboard/src/workflows/actor_runner_name_selector_backfill.rs +++ b/engine/packages/pegboard/src/workflows/actor_runner_name_selector_backfill.rs @@ -161,15 +161,14 @@ pub async fn backfill_batch( } let (key, workflow_id) = tx.read_entry::(&entry)?; - let actor_id = key.actor_id(); // Check if runner_name_selector key exists let runner_name_selector_key = - keys::actor::RunnerNameSelectorKey::new(actor_id); + keys::actor::RunnerNameSelectorKey::new(key.actor_id); let exists = tx.exists(&runner_name_selector_key, Snapshot).await?; if !exists { - actors_missing_runner_name.push((actor_id, workflow_id)); + actors_missing_runner_name.push((key.actor_id, workflow_id)); if actors_missing_runner_name.len() >= batch_size { break;