Skip to main content

unit_state_key

Function unit_state_key 

Source
pub fn unit_state_key(pipeline_name: &str, unit_id: &str) -> String
Expand description

State key a unit’s pipeline invocation reads/advances — the executor’s key for a root node whose id is backfill::{unit} (namespaced away from the live {name}::{row} key, so the forward sync’s bookmark is never touched).