File indexing completed on 2026-09-01 09:34:30
0001 from typing import Any, Mapping
0002
0003
0004 def metadata_with_execution_id(metadata: Mapping[str, Any] | None, execution_id: str | None) -> dict[str, Any]:
0005 result = dict(metadata or {})
0006 if execution_id:
0007 result["workflow_execution_id"] = execution_id
0008 return result
0009
0010
0011 def execution_id_matches(metadata: Mapping[str, Any] | None, execution_id: str | None) -> bool:
0012 if not execution_id:
0013 return True
0014 return (metadata or {}).get("workflow_execution_id") == execution_id
