Skip to content

Commit 691438c

Browse files
author
User
committed
release: version 1.0.6
### Features - Add NanobotServing - lightweight nanobot SDK integration - CLI request retry mechanism with tqdm progress display - Configurable cache_max_size_gb for S3DataSource/S3Storage ### Refactor - LRUCacheManager cache architecture refactoring - Unified Serving class naming with agent health check - Rename temp_dir to cache_dir for consistency ### Fix - Cache size configuration issues - langkit dependency conflict - Type annotations ### Docs - Add usage examples for NanobotServing, CLI retry, and cache config - Update README.md and README-zh.md
1 parent d39b7fd commit 691438c

4 files changed

Lines changed: 170 additions & 2 deletions

File tree

CHANGELOG.md

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,46 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
77

88
---
99

10+
## [1.0.6] - 2026-04-08
11+
12+
### Added
13+
14+
- **NanobotServing** (`5fe27e4`)
15+
- 新增 `NanobotServing` - 基于 nanobot Python SDK 的轻量级 Serving 类
16+
- 新增 `CLINanobotServing` 测试及 API 配置支持
17+
18+
- **CLI 请求增强** (`4502473`)
19+
- 添加 CLI 请求重试机制
20+
- 添加 tqdm 进度显示
21+
22+
- **缓存配置优化** (`e696b26`, `524e002`)
23+
- `S3DataSource``S3Storage``cache_max_size_gb` 改为可配置参数
24+
25+
### Changed
26+
27+
- **缓存架构重构** (`ac516d2`)
28+
- 重构 `LRUCacheManager` 缓存架构
29+
- 将缓存逻辑从 `DataParser` 层移至 `Storage/DataSource`
30+
31+
- **命名统一** (`55a1b50`, `a8d4fe4`)
32+
- `S3Storage``temp_dir` 参数改为 `cache_dir`,统一命名
33+
- `nanobot_serving` 重命名为 `cli_nanobot_serving` 以对齐命名规范
34+
- 重构 `Serving` 类命名并添加 agent 健康检查
35+
36+
### Fixed
37+
38+
- **缓存大小配置** (`722f1a5`, `66b96e4`)
39+
- 修复 cache size 配置问题
40+
- 修复类型注解问题
41+
42+
- **依赖冲突** (`ccfb7af`)
43+
- 解决 langkit 依赖冲突问题
44+
45+
- **临时目录支持** (`40ca1ae`)
46+
-`DataParser` 添加自定义临时目录支持
47+
48+
---
49+
1050
## [1.0.5] - 2026-04-07
1151

1252
### Fixed

README-zh.md

Lines changed: 64 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -629,6 +629,70 @@ serving = create_openclaw_serving(
629629
responses = serving.generate_from_input(["问题 1", "问题 2"])
630630
```
631631

632+
### NanobotServing - 轻量级 Nanobot SDK 集成
633+
634+
```python
635+
from dataflow.serving import NanobotServing
636+
637+
# 创建 NanobotServing
638+
serving = NanobotServing(
639+
model_name="nanobot-model",
640+
max_workers=4,
641+
# 可选:API 配置
642+
api_key="your-api-key",
643+
base_url="https://api.nanobot.example.com",
644+
)
645+
646+
# 生成响应
647+
responses = serving.generate_from_input(
648+
["Prompt 1", "Prompt 2"],
649+
temperature=0.7,
650+
max_tokens=1024,
651+
)
652+
```
653+
654+
### CLI 请求重试和进度显示
655+
656+
```python
657+
from dataflow.serving import CLIOpenClawServing
658+
659+
serving = CLIOpenClawServing(
660+
agent_id="main",
661+
timeout=600,
662+
max_workers=4,
663+
# 重试配置
664+
retry_times=3,
665+
retry_delay=5, #
666+
# 进度显示
667+
show_progress=True,
668+
)
669+
670+
responses = serving.generate_from_input(["问题 1", "问题 2"])
671+
```
672+
673+
### 缓存配置
674+
675+
```python
676+
from dataflow.utils.storage import S3DataSource, S3Storage
677+
678+
# 配置缓存大小(默认:10GB)
679+
data_source = S3DataSource(
680+
endpoint="https://s3.example.com",
681+
ak="xxx",
682+
sk="xxx",
683+
s3_paths=["s3://bucket/data/"],
684+
format_type="jsonl",
685+
cache_dir="/data/cache",
686+
cache_max_size_gb=50.0, # 50GB 缓存
687+
)
688+
689+
storage = S3Storage(
690+
data_source=data_source,
691+
id_key="id",
692+
cache_max_size_gb=50.0, # 与 DataSource 保持一致
693+
)
694+
```
695+
632696
---
633697

634698
## 7. 新增算子使用教程 (v1.0.3)

README.md

Lines changed: 65 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -629,7 +629,7 @@ pipeline.compile()
629629
pipeline.forward(max_parallelism=4) # Concurrent execution
630630
```
631631

632-
### Serving Usage Example
632+
### 2.2 Serving Usage Example
633633

634634
```python
635635
# OpenClaw CLI integration
@@ -643,6 +643,70 @@ serving = create_openclaw_serving(
643643
responses = serving.generate_from_input(["Question 1", "Question 2"])
644644
```
645645

646+
### 2.3 NanobotServing - Lightweight Nanobot SDK Integration
647+
648+
```python
649+
from dataflow.serving import NanobotServing
650+
651+
# Create NanobotServing
652+
serving = NanobotServing(
653+
model_name="nanobot-model",
654+
max_workers=4,
655+
# Optional: API configuration
656+
api_key="your-api-key",
657+
base_url="https://api.nanobot.example.com",
658+
)
659+
660+
# Generate responses
661+
responses = serving.generate_from_input(
662+
["Prompt 1", "Prompt 2"],
663+
temperature=0.7,
664+
max_tokens=1024,
665+
)
666+
```
667+
668+
### 2.4 CLI Request with Retry and Progress
669+
670+
```python
671+
from dataflow.serving import CLIOpenClawServing
672+
673+
serving = CLIOpenClawServing(
674+
agent_id="main",
675+
timeout=600,
676+
max_workers=4,
677+
# Retry configuration
678+
retry_times=3,
679+
retry_delay=5, # seconds
680+
# Progress display
681+
show_progress=True,
682+
)
683+
684+
responses = serving.generate_from_input(["Question 1", "Question 2"])
685+
```
686+
687+
### 2.5 Cache Configuration
688+
689+
```python
690+
from dataflow.utils.storage import S3DataSource, S3Storage
691+
692+
# Configure cache size (default: 10GB)
693+
data_source = S3DataSource(
694+
endpoint="https://s3.example.com",
695+
ak="xxx",
696+
sk="xxx",
697+
s3_paths=["s3://bucket/data/"],
698+
format_type="jsonl",
699+
cache_dir="/data/cache",
700+
cache_max_size_gb=50.0, # 50GB cache
701+
)
702+
703+
storage = S3Storage(
704+
data_source=data_source,
705+
id_key="id",
706+
cache_max_size_gb=50.0, # Same as DataSource
707+
)
708+
```
709+
646710
---
647711

648712
## 7. New Operators Tutorial (v1.0.3)

dataflow/version.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
__version__ = '1.0.5'
1+
__version__ = '1.0.6'
22
short_version = __version__
33

44
def parse_version_info(version_str):

0 commit comments

Comments
 (0)