Cizz22 3 months ago
parent 5bbfa50b4b
commit d3d9436f34

@ -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

@ -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(

@ -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

@ -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")
Loading…
Cancel
Save