pub fn run(
dataflows: &mut [LirDataflowDescription],
read_policies: &BTreeMap<GlobalId, ReadPolicy>,
storage_collections: &dyn StorageCollections,
current_time: Timestamp,
read_only_mode: bool,
pending_replacements: &BTreeSet<GlobalId>,
) -> BTreeMap<GlobalId, ReadHold>Expand description
Runs as-of selection for the given dataflows.
Assigns the selected as-of to the provided dataflow descriptions and returns a set of
ReadHolds that must not be dropped nor downgraded until the dataflows have been installed
with the compute controller.
pending_replacements are the exports of replacement materialized views that are not applied
yet. The downstream storage constraint is soft for them.