Skip to content

Commit f06738f

Browse files
authored
Merge pull request #139 from adf-python/fix/channel-subscribe
Fix channel subscriber conditions
2 parents d7b62ab + 690894c commit f06738f

3 files changed

Lines changed: 7 additions & 108 deletions

File tree

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[project]
22
name = "adf_core_python"
3-
version = "0.2.10"
3+
version = "0.2.11"
44
description = "Agent Development Framework for Python"
55
readme = "README.md"
66
authors = [

src/adf_core_python/core/agent/communication/message_manager.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,10 @@ def subscribe(
215215
if self.__channel_subscriber is None:
216216
raise ValueError("ChannelSubscriber is not set.")
217217

218-
if agent_info.get_time() == 1:
218+
if (
219+
agent_info.get_time()
220+
== scenario_info.get_value(ScenarioInfoKeys.KERNEL_AGENTS_IGNOREUNTIL, 0) + 1
221+
):
219222
self.__subscribed_channels = self.__channel_subscriber.subscribe(
220223
agent_info, world_info, scenario_info
221224
)

0 commit comments

Comments
 (0)