Skip to content

Commit 955f488

Browse files
committed
add log to ASM Event
1 parent 17e0666 commit 955f488

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

fabric_cf/actor/fim/asm_update_thread.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,14 +43,17 @@ class AsmUpdateException(Exception):
4343

4444
class AsmEvent:
4545
def __init__(self, *, graph_id: str, sliver: BaseSliver, reservation_id: str,
46-
state: str, error_message: str):
46+
state: str, error_message: str, logger: logging.Logger = None):
4747
self.graph_id = graph_id
4848
self.sliver = sliver
4949
self.reservation_id = reservation_id
5050
self.state = state
5151
self.error_message = error_message
52+
self.logger = logger
5253

5354
def process(self):
55+
if self.logger:
56+
self.logger.info(f"AsmEvent for Res# {self.reservation_id} State: {self.state} Graph: {self.graph_id}")
5457
FimHelper.update_node(graph_id=self.graph_id, sliver=self.sliver, reservation_id=self.reservation_id,
5558
state=self.state, error_message=self.error_message)
5659

@@ -124,7 +127,7 @@ def enqueue(self, *, graph_id: str, sliver: BaseSliver, rid: str, reservation_st
124127
error_message: str):
125128
try:
126129
event = AsmEvent(graph_id=graph_id, sliver=sliver, reservation_id=rid,
127-
state=reservation_state, error_message=error_message)
130+
state=reservation_state, error_message=error_message, logger=self.logger)
128131
self.event_queue.put_nowait(event)
129132
with self.condition:
130133
self.condition.notify_all()

0 commit comments

Comments
 (0)