diff --git a/.env b/.env index abbd43f..5d5ce8a 100644 --- a/.env +++ b/.env @@ -17,3 +17,4 @@ COLLECTOR_NAME=digital_aeros_fixed WINDOWS_AEROS_BASE_URL=http://192.168.1.102:8800 +TEMPORAL_URL=http://192.168.1.86:7233 \ No newline at end of file diff --git a/run_worker.py b/run_worker.py index 21f7fec..678c899 100644 --- a/run_worker.py +++ b/run_worker.py @@ -1,14 +1,15 @@ import asyncio +import os from temporalio.client import Client from temporalio.worker import Worker from temporal.activity import calculate_plant_eaf_activity, execute_simulation_activity, update_contribution_bulk_mappings_activity, update_equipment_for_simulation_activity from temporal.workflow import SimulationWorkflow - +TEMPORAL_URL = os.environ.get("TEMPORAL_URL", "http://192.168.1.86:7233") async def main(): - client = await Client.connect("http://temporal:7233") + client = await Client.connect(TEMPORAL_URL) try: worker = Worker( diff --git a/src/aeros_simulation/router.py b/src/aeros_simulation/router.py index 1e6bf5e..e1dc9b8 100644 --- a/src/aeros_simulation/router.py +++ b/src/aeros_simulation/router.py @@ -10,6 +10,7 @@ from src.aeros_contribution.service import update_contribution_bulk_mappings from src.aeros_equipment.model import AerosEquipment from src.aeros_simulation.model import EafContribution from src.auth.service import CurrentUser +from src.config import TEMPORAL_URL from src.database.core import CollectorDbSession, DbSession from src.database.service import CommonParameters from src.models import StandardResponse @@ -79,7 +80,7 @@ async def run_simulations( ): """RUN Simulation""" - temporal_client = await Client.connect("http://temporal:7233") + temporal_client = await Client.connect(TEMPORAL_URL) simulation = await create_simulation( db_session=db_session, simulation_in=simulation_in diff --git a/src/config.py b/src/config.py index b257238..640d01d 100644 --- a/src/config.py +++ b/src/config.py @@ -92,3 +92,4 @@ AEROS_BASE_URL_OLD = config("AEROS_BASE_URL_OLD", default="http://192.168.1.87") WINDOWS_AEROS_BASE_URL = config("WINDOWS_AEROS_BASE_URL", default="http://192.168.1.102:8800") DEFAULT_PROJECT_NAME = config("DEFAULT_PROJECT_NAME", default="RBD TJB") +TEMPORAL_URL = config("TEMPORAL_URL", default="http://192.168.1.86:7233") \ No newline at end of file