in data_validation/__main__.py [0:0]
def build_config_managers_from_yaml(args, config_file_path):
"""Returns List[ConfigManager] instances ready to be executed."""
if args.config_dir:
yaml_configs = cli_tools.get_validation(config_file_path, args.config_dir)
else:
yaml_configs = cli_tools.get_validation(config_file_path)
mgr = state_manager.StateManager()
source_conn = mgr.get_connection_config(yaml_configs[consts.YAML_SOURCE])
target_conn = mgr.get_connection_config(yaml_configs[consts.YAML_TARGET])
source_client = clients.get_data_client(source_conn)
target_client = clients.get_data_client(target_conn)
config_managers = []
for config in yaml_configs[consts.YAML_VALIDATIONS]:
config[consts.CONFIG_SOURCE_CONN] = source_conn
config[consts.CONFIG_TARGET_CONN] = target_conn
config[consts.CONFIG_RESULT_HANDLER] = yaml_configs[consts.YAML_RESULT_HANDLER]
config_manager = ConfigManager(
config, source_client, target_client, verbose=args.verbose
)
config_manager.config[consts.CONFIG_FILE] = config_file_path
config_managers.append(config_manager)
return config_managers