|
4 | 4 | from pathlib import Path |
5 | 5 | from typing import cast, Dict, List, Tuple, Optional |
6 | 6 |
|
| 7 | +from mesido.esdl.esdl_mixin import DBAccesType |
7 | 8 | from mesido.exceptions import MesidoAssetIssueError |
8 | 9 | from omotes_sdk.internal.orchestrator_worker_events.esdl_messages import ( |
9 | 10 | EsdlMessage, |
@@ -80,12 +81,17 @@ def grow_worker_task( |
80 | 81 | esdl_string=base64.encodebytes(input_esdl.encode("utf-8")), |
81 | 82 | esdl_parser=ESDLStringParser, |
82 | 83 | write_result_db_profiles=write_result_db_profiles, |
83 | | - influxdb_host=influxdb_host, |
84 | | - influxdb_port=influxdb_port, |
85 | | - influxdb_username=os.environ.get("INFLUXDB_USERNAME"), |
86 | | - influxdb_password=os.environ.get("INFLUXDB_PASSWORD"), |
87 | | - influxdb_ssl=False, |
88 | | - influxdb_verify_ssl=False, |
| 84 | + database_connections=[ |
| 85 | + { |
| 86 | + "access_type": DBAccesType.READ_WRITE, |
| 87 | + "influxdb_host": influxdb_host, |
| 88 | + "influxdb_port": influxdb_port, |
| 89 | + "influxdb_username": os.environ.get("INFLUXDB_USERNAME"), |
| 90 | + "influxdb_password": os.environ.get("INFLUXDB_PASSWORD"), |
| 91 | + "influxdb_ssl": False, |
| 92 | + "influxdb_verify_ssl": False, |
| 93 | + }, |
| 94 | + ], |
89 | 95 | update_progress_function=update_progress_handler, |
90 | 96 | profile_reader=InfluxDBProfileReader, |
91 | 97 | ) |
|
0 commit comments