From 3a9f588dd2ed9154dd049f4c05ec5ea244a05545 Mon Sep 17 00:00:00 2001 From: Mark Vrijlandt Date: Mon, 9 Feb 2026 10:53:47 +0100 Subject: [PATCH] add database connections argument --- .github/workflows/publish_container_image.yml | 8 ++++---- src/grow_worker/worker.py | 18 ++++++++++++------ 2 files changed, 16 insertions(+), 10 deletions(-) diff --git a/.github/workflows/publish_container_image.yml b/.github/workflows/publish_container_image.yml index d366636..f5e3dc6 100644 --- a/.github/workflows/publish_container_image.yml +++ b/.github/workflows/publish_container_image.yml @@ -1,8 +1,8 @@ name: Deply to GitHub Container Registry -on: - push: - tags: - - '*' +on: [push] +# push: +# tags: +# - '*' jobs: publish-container-image: diff --git a/src/grow_worker/worker.py b/src/grow_worker/worker.py index 9400ca1..e351e34 100644 --- a/src/grow_worker/worker.py +++ b/src/grow_worker/worker.py @@ -4,6 +4,7 @@ from pathlib import Path from typing import cast, Dict, List, Tuple, Optional +from mesido.esdl.esdl_mixin import DBAccesType from mesido.exceptions import MesidoAssetIssueError from omotes_sdk.internal.orchestrator_worker_events.esdl_messages import ( EsdlMessage, @@ -80,12 +81,17 @@ def grow_worker_task( esdl_string=base64.encodebytes(input_esdl.encode("utf-8")), esdl_parser=ESDLStringParser, write_result_db_profiles=write_result_db_profiles, - influxdb_host=influxdb_host, - influxdb_port=influxdb_port, - influxdb_username=os.environ.get("INFLUXDB_USERNAME"), - influxdb_password=os.environ.get("INFLUXDB_PASSWORD"), - influxdb_ssl=False, - influxdb_verify_ssl=False, + database_connections=[ + { + "access_type": DBAccesType.READ_WRITE, + "influxdb_host": influxdb_host, + "influxdb_port": influxdb_port, + "influxdb_username": os.environ.get("INFLUXDB_USERNAME"), + "influxdb_password": os.environ.get("INFLUXDB_PASSWORD"), + "influxdb_ssl": False, + "influxdb_verify_ssl": False, + }, + ], update_progress_function=update_progress_handler, profile_reader=InfluxDBProfileReader, )