Implement atomic add method and advisory locking in Channel interface#45

Merged

myui merged 21 commits intomainfrom

atomic-ops

Apr 5, 2026

Commits on Apr 5, 2026

feat: add atomic add method and advisory lock to Channel interface
myui
committed
feat: rename add method to atomic_add for clarity in Channel interface
myui
committed
feat: implement atomic_add method and advisory locking in MemoryChannel
myui
committed
feat: add atomic_add method for atomic arithmetic in RedisChannel
myui
committed
test: add thread safety tests for MemoryChannel and atomic_add method
myui
committed
docs: update README and add channel concurrency example for thread-safe operations
myui
committed
refactor: simplify atomic_add method by removing counter key logic and using generic key retrieval
myui
committed
test: add additional tests for atomic_add method in MemoryChannel
myui
committed
Update graflow/channels/memory_channel.py

myui
and
Copilot
authored
Update examples/03_data_flow/channel_concurrency.py

myui
and
Copilot
authored
Update graflow/channels/base.py

myui
and
Copilot
authored
docs: enhance warning for lock method in Channel class to clarify no mutual exclusion
myui
committed
docs: clarify atomic_add and lock method descriptions in README
myui
committed
feat: add distributed advisory lock method to RedisChannel
myui
committed
docs: enhance lock method documentation to clarify mutual exclusion and timeout behavior
myui
committed
adjust formatting in __setstate__ method for consistency
myui
committed
Update tests/channels/test_memory_channel_thread_safety.py

myui
and
Copilot
authored
test: add timeout assertion for lock acquisition in TestAdvisoryLock
myui
committed
docs: clarify advisory lock documentation to emphasize safe usage and coordination
myui
committed
Update examples/03_data_flow/channel_concurrency.py

myui
and
Copilot
authored
Update graflow/channels/memory_channel.py

myui
and
Copilot
authored

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Implement atomic add method and advisory locking in Channel interface#45

Implement atomic add method and advisory locking in Channel interface#45
myui merged 21 commits intomainfrom
atomic-ops

Commits on Apr 5, 2026

feat: add atomic add method and advisory lock to Channel interface

feat: rename add method to atomic_add for clarity in Channel interface

feat: implement atomic_add method and advisory locking in MemoryChannel

feat: add atomic_add method for atomic arithmetic in RedisChannel

test: add thread safety tests for MemoryChannel and atomic_add method

docs: update README and add channel concurrency example for thread-safe operations

refactor: simplify atomic_add method by removing counter key logic and using generic key retrieval

test: add additional tests for atomic_add method in MemoryChannel

Update graflow/channels/memory_channel.py

Update examples/03_data_flow/channel_concurrency.py

Update graflow/channels/base.py

docs: enhance warning for lock method in Channel class to clarify no mutual exclusion

docs: clarify atomic_add and lock method descriptions in README

feat: add distributed advisory lock method to RedisChannel

docs: enhance lock method documentation to clarify mutual exclusion and timeout behavior

adjust formatting in setstate method for consistency

Update tests/channels/test_memory_channel_thread_safety.py

test: add timeout assertion for lock acquisition in TestAdvisoryLock

docs: clarify advisory lock documentation to emphasize safe usage and coordination

Update examples/03_data_flow/channel_concurrency.py

Update graflow/channels/memory_channel.py