@@ -602,6 +602,7 @@ def update_model_outages(merged_model: object, tso_list: list, scenario_datetime
602602 # rename columns
603603 filtered_model_outages = filtered_model_outages .copy ()[['name' , 'grid_id' , 'eic' ]].rename (columns = {'grid_id' : 'mrid' })
604604 mapped_outages = mapped_outages [['name' , 'mrid' , 'eic' ]].copy ()
605+ mapped_outages .loc [:, 'mrid' ] = mapped_outages ['mrid' ].str .lstrip ('_' )
605606
606607 logger .info ("Updating outages on merged model" )
607608
@@ -637,13 +638,13 @@ def update_model_outages(merged_model: object, tso_list: list, scenario_datetime
637638 outage_dict .update ({'status' : 'disconnected' })
638639 outages_updated [outage_dict ['mrid' ]] = outage_dict
639640 else :
640- if uap_outages ['grid_id ' ].str .contains (outage ['mrid' ]).any ():
641+ if uap_outages ['mrid ' ].str .contains (( "_" + outage ['mrid' ]) ).any ():
641642 logger .info (f"Element is already in outage: { outage ['name' ]} [mrid: { outage ['mrid' ]} ]" )
642643 else :
643644 logger .error (f"Failed to disconnect element: { outage ['name' ]} [mrid: { outage ['mrid' ]} ]" )
644645 merged_model .outages_unmapped .extend ([{"name" : outage ['name' ], "mrid" : outage ['mrid' ], "eic" : outage ['eic' ]}])
645646 except Exception as e :
646- logger .error ((e , outage ['name' ]))
647+ logger .error ((e , outage ['name' ], outage [ 'mrid' ] ))
647648 merged_model .outages_unmapped .extend ([{"name" : outage ['name' ], "mrid" : outage ['mrid' ], "eic" : outage ['eic' ]}])
648649 merged_model .outages = False
649650 continue
0 commit comments