Update plan Task 9: PMNotify calls stage_notify directly (trace on failed runs)
This commit is contained in:
@@ -2119,8 +2119,9 @@ class PMNotify(Component):
|
|||||||
|
|
||||||
def build_out(self) -> Message:
|
def build_out(self) -> Message:
|
||||||
cfg = Cfg(imap_password=self.imap_password, notify_to=self.notify_to)
|
cfg = Cfg(imap_password=self.imap_password, notify_to=self.notify_to)
|
||||||
ctx = stages.run_stage("notify", stages.stage_notify,
|
# stage_notify is called DIRECTLY (not via run_stage): it must run for
|
||||||
dict(self.ctx.data), cfg)
|
# every terminal status so failed runs still post their Langfuse trace.
|
||||||
|
ctx = stages.stage_notify(dict(self.ctx.data), cfg)
|
||||||
self.status = ctx.get("status", "")
|
self.status = ctx.get("status", "")
|
||||||
return Message(text=stages.summary(ctx))
|
return Message(text=stages.summary(ctx))
|
||||||
```
|
```
|
||||||
|
|||||||
Reference in New Issue
Block a user