noetl-tools 2.24.2

NoETL Tool Library - Shared tool implementations for workflow execution
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

//! DuckLake tool (compatibility alias to DuckDB).

use async_trait::async_trait;

use crate::context::ExecutionContext;
use crate::error::ToolError;
use crate::registry::{Tool, ToolConfig};
use crate::result::ToolResult;
use crate::tools::duckdb::DuckdbTool;

/// DuckLake compatibility tool.
///
/// Python runtime exposes `ducklake` as a first-class tool kind.
/// In Rust we map it to DuckDB execution semantics.
pub struct DucklakeTool {
    inner: DuckdbTool,
}

impl DucklakeTool {
    /// Create a new ducklake compatibility tool.
    pub fn new() -> Self {
        Self {
            inner: DuckdbTool::new(),
        }
    }
}

impl Default for DucklakeTool {
    fn default() -> Self {
        Self::new()
    }
}

#[async_trait]
impl Tool for DucklakeTool {
    fn name(&self) -> &'static str {
        "ducklake"
    }

    async fn execute(
        &self,
        config: &ToolConfig,
        ctx: &ExecutionContext,
    ) -> Result<ToolResult, ToolError> {
        self.inner.execute(config, ctx).await
    }
}