feat: Add conversation variable persistence layer by laipz8200 · Pull Request #30531 · langgenius/dify

Added constructor-based DI for VariableAssigner v2 and wired the node factory to pass the ConversationVariableUpdater factory (the only non-VariablePool dependency), plus a unit test to verify the …

laipz8200

committed

Updated to avoid the dict path and let the type checker enforce constructor args.

laipz8200

committed

A new command for updating variables. (vibe-kanban 00377ffe)

laipz8200

committed

Add a new persistent storage for handling Conversation Variables. (vibe-kanban 0941477f)

laipz8200

committed

- fix(lint): replace `outputs.keys()` iteration in `api/core/app/layers/conversation_variable_persist_layer.py` to satisfy SIM118

laipz8200

committed

- feat(graph-engine): enforce variable update value types with SegmentType validation and casting

laipz8200

committed

- refactor(variable-assigner-v1): inline updated variable payload and drop common_helpers usage

laipz8200

committed

- refactor(graph-engine): switch VariableUpdate.value to VariableUnion and remove value type validation

laipz8200

committed

- refactor(variable-assigner): restore common_helpers updated-variable handling for v1/v2 process_data

laipz8200

committed

- refactor(variable-assigner): drop updated outputs now that persistence reads from process_data

laipz8200

committed

- chore(lint): run `make lint` (fails: dotenv-linter module missing after venv changes)

laipz8200

committed

Revert "- refactor(graph-engine): switch VariableUpdate.value to VariableUnion and remove value type validation"

laipz8200

committed

Revert "- feat(graph-engine): enforce variable update value types with SegmentType validation and casting"

laipz8200

committed

Revert "A new command for updating variables. (vibe-kanban 00377ffe)"

laipz8200

committed

- refactor(services): move ConversationVariableUpdaterImpl and factory out of core.workflow into `api/services/conversation_variable_updater.py`

laipz8200

committed

- chore(lint): run `make lint` (fails: import linter error and dotenv-linter module missing)

laipz8200

committed

- chore(import-linter): remove obsolete ignore for variable_assigner impl import in `api/.importlinter`

laipz8200

committed

fix(core): guard conversation variable flush when no updates

laipz8200

committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat: Add conversation variable persistence layer #30531

feat: Add conversation variable persistence layer #30531
QuantumGhost merged 20 commits intomainfrom
54a0-node-di-variable

Commits on Jan 5, 2026

Added constructor-based DI for VariableAssigner v2 and wired the node factory to pass the ConversationVariableUpdater factory (the only non-VariablePool dependency), plus a unit test to verify the …

Updated to avoid the dict path and let the type checker enforce constructor args.

A new command for updating variables. (vibe-kanban 00377ffe)

Add a new persistent storage for handling Conversation Variables. (vibe-kanban 0941477f)

- fix(lint): replace `outputs.keys()` iteration in `api/core/app/layers/conversation_variable_persist_layer.py` to satisfy SIM118

- feat(graph-engine): enforce variable update value types with SegmentType validation and casting

- refactor(variable-assigner-v1): inline updated variable payload and drop common_helpers usage

- refactor(graph-engine): switch VariableUpdate.value to VariableUnion and remove value type validation

- refactor(variable-assigner): restore common_helpers updated-variable handling for v1/v2 process_data

- refactor(variable-assigner): drop updated outputs now that persistence reads from process_data

- chore(lint): run `make lint` (fails: dotenv-linter module missing after venv changes)

Revert "- refactor(graph-engine): switch VariableUpdate.value to VariableUnion and remove value type validation"

Revert "- feat(graph-engine): enforce variable update value types with SegmentType validation and casting"

Revert "A new command for updating variables. (vibe-kanban 00377ffe)"

- refactor(services): move ConversationVariableUpdaterImpl and factory out of core.workflow into `api/services/conversation_variable_updater.py`

- chore(lint): run `make lint` (fails: import linter error and dotenv-linter module missing)

- chore(import-linter): remove obsolete ignore for variable_assigner impl import in `api/.importlinter`

fix(core): guard conversation variable flush when no updates

Commits on Jan 6, 2026

fix(core): use system variable conversation_id and add custom updater error

fix(services): use Exception for conversation variable not found