This commit is contained in:
Tat Dat Duong
2024-10-08 16:41:48 +02:00
parent dfb265f296
commit c1081af6bc
+1 -1
View File
@@ -154,7 +154,7 @@ def map_debug_checkpoint(
"""Produce "checkpoint" events for stream_mode=debug."""
parent_ns = config[CONF].get(CONFIG_KEY_CHECKPOINT_NS, "")
task_states: dict[str, RunnableConfig] = {}
task_states: dict[str, Union[RunnableConfig, StateSnapshot]] = {}
for task in tasks:
subgraph = None