|
2 | 2 |
|
3 | 3 | ## v0.1.2 |
4 | 4 |
|
5 | | -### Internal Improvements |
| 5 | +### New Features |
6 | 6 |
|
7 | | -**Refactored Redis client usage** |
8 | | -- Added `get_redis_sync()` for synchronous Redis operations |
9 | | -- Worker logging now uses sync Redis client (required for `logging.Handler.emit()`) |
| 7 | +**Pipelines** |
| 8 | +- Multi-step workflow orchestration with `ax.Pipeline` |
| 9 | +- Define steps with `@pipeline.step(order)` decorator |
| 10 | +- Parallel task execution with `ax.gather()` |
| 11 | +- Result retrieval with `ax.get_result()` |
10 | 12 |
|
11 | | -**Simplified WorkerPool shutdown** |
12 | | -- `RedisEvent.set()` and `clear()` are now synchronous |
13 | | -- `WorkerPool.run()` now reuses `start()` to avoid code duplication |
14 | | -- Removed nested `asyncio.run()` calls in pool lifecycle methods |
| 13 | +**Worker logging via Redis pubsub** |
| 14 | +- Workers publish logs to Redis, collected by main process |
| 15 | +- Use `pool.run()` to see worker logs in real-time |
| 16 | + |
| 17 | +### Internal Improvements |
15 | 18 |
|
16 | 19 | **Reorganized worker module** |
17 | | -- Moved `RedisEvent` from `core/sync.py` to `worker/event.py` |
18 | | -- Removed unused `RedisEvent.wait()` method |
| 20 | +- Worker code moved to `agentexec.worker` subpackage |
| 21 | +- `RedisEvent` for cross-process shutdown coordination |
| 22 | +- `get_worker_logger()` configures logging and returns logger in one call |
| 23 | + |
| 24 | +**Refactored Redis client usage** |
| 25 | +- Added `get_redis_sync()` for synchronous Redis operations |
| 26 | +- Sync/async Redis clients for different contexts |
19 | 27 |
|
20 | 28 | ## v0.1.1 |
21 | 29 |
|
|
0 commit comments