fix

src/aeros_equipment/service.py

@@ -266,9 +266,10 @@ def get_asset_batch(location_tags: List[str], nr_location_tags: List[str],
                 continue
             
             try:
-                is_nr = item["distribution"] != "NHPP"
+                # is_nr = item["distribution"] != "NHPP"
-                mtbf = item["mtbf"]
+                # mtbf = item["mtbf"]
-                mttr = item["mttr"]
+                # mttr = item["mttr"]
+                print(item)
                 distribution, reldisp1, reldisp2 = get_distribution(item)
                 
                 results[location_tag]["cmDisType"] = "Normal"
@@ -438,7 +439,9 @@ async def update_equipment_for_simulation(*, db_session: DbSession,aeros_db_sess
                 # eq["ohDisUnitCode"] = "UHour"
                     
                 # if eq["equipmentName"] in trip_eq:
+                eq["cmDisType"] = reliabiility.get("cmDisType", "Fixed")
                 eq["cmDisP1"] = reliabiility.get("cmDisP1", 0)
+                eq["cmDisP2"] = reliabiility.get("cmDisP2", 0)
                 eq["relDisType"] = reliabiility.get("relDisType", "Fixed")
                 eq["relDisP1"] = reliabiility.get("relDisP1", 0)
                 eq["relDisP2"] = reliabiility.get("relDisP2", 0)

src/aeros_simulation/router.py

@@ -93,44 +93,6 @@ async def run_simulations(
     sim_data["HubCnnId"] = str(simulation_id)
     sim_data["projectName"] = project.project_name
 
-    # # Prepare async background task
-    # async def run_full_simulation():
-    #     try:
-    #         results = await update_equipment_for_simulation(
-    #             db_session=db_session,
-    #             project_name=project.project_name,
-    #             schematic_name=simulation_in.SchematicName,
-    #             overhaul_duration=simulation_in.OverhaulDuration,
-    #             overhaul_interval=simulation_in.OverhaulInterval,
-    #             offset=simulation_in.OffSet,
-    #             custom_input=simulation_in.CustomInput,
-    #         )
-
-    #         await execute_simulation(
-    #             db_session=db_session,
-    #             simulation_id=simulation_id,
-    #             sim_data=sim_data,
-    #             is_saved=True,
-    #             eq_update=results,
-    #         )
-
-    #         await calculate_plant_eaf(
-    #             db_session=db_session,
-    #             simulation_id=simulation_id,
-    #             is_default=simulation_in.IsDefault,
-    #             konkin_offset=simulation_in.Konkin_offset,
-    #         )
-
-    #         await update_contribution_bulk_mappings(
-    #             db_session=db_session, simulation_id=simulation_id
-    #         )
-
-    #     except Exception as e:
-    #         # TODO: log error into DB or logger
-    #         print(f"Simulation {simulation_id} failed: {e}")
-
-    # # Add to background
-    # background_tasks.add_task(run_full_simulation)
     
     handle = await temporal_client.start_workflow(
         SimulationWorkflow.run,