v0.1.2

v0.1.2

New Features

Pipelines

• Multi-step workflow orchestration with ax.Pipeline
• Define steps with @pipeline.step(order) decorator
• Parallel task execution with ax.gather()
• Result retrieval with ax.get_result()

Worker logging via Redis pubsub

• Workers publish logs to Redis, collected by main process
• Use pool.run() to see worker logs in real-time

Internal Improvements

Reorganized worker module

• Worker code moved to agentexec.worker subpackage
• RedisEvent for cross-process shutdown coordination
• get_worker_logger() configures logging and returns logger in one call

Refactored Redis client usage

• Added get_redis_sync() for synchronous Redis operations
• Sync/async Redis clients for different contexts