|
12 | 12 |
|
13 | 13 |
|
14 | 14 | try:
|
15 |
| - sz_factory = SzAbstractFactoryCore("add_records", SETTINGS, verbose_logging=False) |
16 |
| - sz_config = sz_factory.create_config() |
| 15 | + sz_factory = SzAbstractFactoryCore("add_data_source", SETTINGS, verbose_logging=False) |
17 | 16 | sz_configmanager = sz_factory.create_configmanager()
|
18 | 17 |
|
19 | 18 | config_id = sz_configmanager.get_default_config_id()
|
20 |
| - config_definition = sz_configmanager.get_config(config_id) |
21 |
| - config_handle = sz_config.import_config(config_definition) |
| 19 | + sz_config = sz_configmanager.create_config_from_config_id(config_id) |
22 | 20 |
|
23 | 21 | for data_source in ("CUSTOMERS", "REFERENCE", "WATCHLIST"):
|
24 |
| - response = sz_config.add_data_source(config_handle, data_source) |
| 22 | + _ = sz_config.add_data_source(data_source) |
25 | 23 |
|
26 |
| - config_definition = sz_config.export_config(config_handle) |
27 |
| - config_id = sz_configmanager.add_config(config_definition, INSTANCE_NAME) |
| 24 | + new_config = sz_config.export() |
| 25 | + new_config_id = sz_configmanager.register_config(new_config, INSTANCE_NAME) |
28 | 26 | sz_configmanager.set_default_config_id(config_id)
|
29 | 27 |
|
30 |
| - response2 = sz_config.get_data_sources(config_handle) |
31 |
| - sz_config.close_config(config_handle) |
32 |
| - print(response2) |
| 28 | + sz_config = sz_configmanager.create_config_from_config_id(new_config_id) |
| 29 | + response = sz_config.get_data_sources() |
| 30 | + print(response) |
33 | 31 | except SzError as err:
|
34 | 32 | print(f"{err.__class__.__name__} - {err}", file=sys.stderr)
|
0 commit comments