ContextEquals

Fires when state.context_vars[key] equals value.

The session-scoped context dict is mutated by ag2.context.set envelopes; this condition is the read side. Missing keys compare as None so ContextEquals(key="foo", value=None) fires when foo has never been set or was deleted.

key

value

name = 'context_equals'

evaluate(state, envelope)

239
240

def evaluate(self, state: "WorkflowState", envelope: Envelope) -> bool:
    return state.context_vars.get(self.key) == self.value