# Pastebin HeGAWrVU from sir.schema import SCHEMA, generate_update_map from sir.util import db_session from sir.trigger_generation.paths import last_model_in_path from sir.config import read_config from sqlalchemy.orm import class_mapper read_config() update_map = generate_update_map() ids = ["12"] dbs = db_session()() for key in update_map: for core_name, path in update_map[key]: entity_model = SCHEMA[core_name].model if path is not None: last_model = class_mapper(last_model_in_path(entity_model, path)) pks = list(pk.in_(ids) for pk in last_model.mapper.primary_key) query = dbs.query(entity_model.id).join(*path.split(".")).filter(*pks) print("-"*50) print("On updating: `%s`, We update entity: `%s` via path: `%s`" % (key, core_name, path)) print(query) print("-"*50)