Skip to content

Commit

Permalink
[CLN] Cleanup query node after pushdown
Browse files Browse the repository at this point in the history
  • Loading branch information
Sicheng Pan authored and Sicheng-Pan committed Dec 11, 2024
1 parent a952add commit 9287004
Show file tree
Hide file tree
Showing 13 changed files with 7 additions and 2,834 deletions.
3 changes: 3 additions & 0 deletions rust/worker/src/execution/operator.rs
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,7 @@ where
#[derive(Debug)]
pub(super) struct TaskResult<Output, Error> {
result: Result<Output, TaskError<Error>>,
#[allow(dead_code)]
task_id: Uuid,
}

Expand All @@ -73,6 +74,7 @@ impl<Output, Error> TaskResult<Output, Error> {
self.result
}

#[allow(dead_code)]
pub(super) fn id(&self) -> Uuid {
self.task_id
}
Expand Down Expand Up @@ -101,6 +103,7 @@ pub(crate) type TaskMessage = Box<dyn TaskWrapper>;
pub(crate) trait TaskWrapper: Send + Debug {
fn get_name(&self) -> &'static str;
async fn run(&self);
#[allow(dead_code)]
fn id(&self) -> Uuid;
fn get_type(&self) -> OperatorType;
}
Expand Down
Loading

0 comments on commit 9287004

Please sign in to comment.