fn block_on_migrations(
        &mut self,
        modified_instances: &[(InstanceState, ModifiedInstanceInfo)],
        schema: &mut Schema<&Fork>,
    ) {
        let committed_migrations = modified_instances.iter().filter(|(_, modified_info)| {
            modified_info.migration_transition == Some(MigrationTransition::Commit)
        });
        for (state, _) in committed_migrations {
            let migration_hash = state
                .status
                .as_ref()
                .and_then(InstanceStatus::completed_migration_hash)
                .expect("BUG: No migration hash saved for committed migration");

            let instance_name = &state.spec.name;
            let local_result = schema.local_migration_result(instance_name);
            let local_result = self.block_on_migration(instance_name, migration_hash, local_result);
            schema.add_local_migration_result(instance_name, local_result);
        }
    }
/// Blocks until all committed migrations are completed with the expected outcome.
/// The node will panic if the local outcome of a migration is unexpected.
Blocks until all committed migrations are completed with the expected outcome.
The node will panic if the local outcome of a migration is unexpected.
Blocks until all committed migrations are completed with the expected outcome . The node will panic if the local outcome of a migration is unexpected .
fn block_on_migrations(
        &mut self,
        modified_instances: &[(InstanceState, ModifiedInstanceInfo)],
        schema: &mut Schema<&Fork>,
    ) {
        let committed_migrations = modified_instances.iter().filter(|(_, modified_info)| {
            modified_info.migration_transition == Some(MigrationTransition::Commit)
        });
        for (state, _) in committed_migrations {
            let migration_hash = state
                .status
                .as_ref()
                .and_then(InstanceStatus::completed_migration_hash)
                .expect("BUG: No migration hash saved for committed migration");
            let instance_name = &state.spec.name;
            let local_result = schema.local_migration_result(instance_name);
            let local_result = self.block_on_migration(instance_name, migration_hash, local_result);
            schema.add_local_migration_result(instance_name, local_result);
        }
    }
fn block_on_migrations ( & mut self , modified_instances : & [ ( InstanceState , ModifiedInstanceInfo ) ] , schema : & mut Schema < & Fork > , ) { let committed_migrations = modified_instances . iter ( ) . filter ( | ( _ , modified_info ) | { modified_info . migration_transition == Some ( MigrationTransition :: Commit ) } ) ; for ( state , _ ) in committed_migrations { let migration_hash = state . status . as_ref ( ) . and_then ( InstanceStatus :: completed_migration_hash ) . expect ( " " ) ; let instance_name = & state . spec . name ; let local_result = schema . local_migration_result ( instance_name ) ; let local_result = self . block_on_migration ( instance_name , migration_hash , local_result ) ; schema . add_local_migration_result ( instance_name , local_result ) ; } }
Blocks until all committed migrations are completed with the expected outcome.
Blocks until all committed migrations are completed with the expected outcome .
&mut self
modified_instances
&[(InstanceState, ModifiedInstanceInfo)]
schema
&mut Schema<&Fork>
&mut self
modified_instances
&[(InstanceState, ModifiedInstanceInfo)]
schema
&mut Schema<&Fork>