Cizz22 3 months ago
parent 509c9b6a34
commit 43a3aba7bf

@ -63,6 +63,28 @@ async def get_target_reliability(
sim_hours=duration,
token=token
)
workflow_id = f"simulation-{simulation_id}"
while True:
try:
handle = temporal_client.get_workflow_handle(workflow_id=workflow_id)
desc = await handle.describe()
status = desc.status.name
if status not in ["RUNNING", "CONTINUED_AS_NEW"]:
print(f"Workflow {workflow_id} finished with status: {status}")
return status
print(f"Workflow {workflow_id} still {status}, checking again in {interval} seconds...")
except WorkflowNotFoundError:
print(f"Workflow {workflow_id} not found, treating as done.")
return "NOT_FOUND"
await asyncio.sleep(interval)
results = await get_simulation_results(
simulation_id=simulation_id,

@ -139,6 +139,9 @@ async def update_selected_equipment(
calculation_id,
calculation_time_constrains_in: List[CalculationSelectedEquipmentUpdate],
):
if calculation_id == 'default':
calculation_id = "3b9a73a2-bde6-418c-9e2f-19046f501a05"
results = await bulk_update_equipment(
db=db_session,
selected_equipments=calculation_time_constrains_in,

Loading…
Cancel
Save