Skip to content

Commit b037443

Browse files
committed
Update README and enhance wait operation with timeout error handling
1 parent be6dc00 commit b037443

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
# AgentForge
22

3-
[![CI](https://github.com/i365dev/agent_forge/actions/workflows/ci.yml/badge.svg)](https://github.com/USERNAME/agent_forge/actions/workflows/ci.yml)
3+
[![CI](https://github.com/i365dev/agent_forge/actions/workflows/ci.yml/badge.svg)](https://github.com/i365dev/agent_forge/actions/workflows/ci.yml)
44
[![Hex.pm](https://img.shields.io/hexpm/v/agent_forge.svg)](https://hex.pm/packages/agent_forge)
55
[![Docs](https://img.shields.io/badge/hex-docs-blue.svg)](https://hexdocs.pm/agent_forge)
66
[![License](https://img.shields.io/hexpm/l/agent_forge.svg)](https://github.com/i365dev/agent_forge/blob/main/LICENSE)

lib/agent_forge/primitives.ex

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,8 +169,10 @@ defmodule AgentForge.Primitives do
169169
cond do
170170
condition.(signal, state) ->
171171
{{:emit, signal}, state}
172+
172173
elapsed_time >= timeout ->
173174
{{:emit, Signal.new(:error, "Wait operation timed out after #{timeout}ms")}, state}
175+
174176
true ->
175177
Process.sleep(retry_interval)
176178
# Keep original message format for backward compatibility

0 commit comments

Comments
 (0)