rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-22 07:50:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: load with latest

Browse Source 
Signed-off-by: shuiyisong <xixing.sys@gmail.com>
This commit is contained in:
shuiyisong
2025-12-23 20:18:36 +08:00
parent 4b3e60c1d3
commit 8cc43fd848
1 changed files with 15 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/pipeline/src/manager/table.rs
View File

@@ -267,8 +267,13 @@ impl PipelineTable {
let pipeline = self.get_pipeline_str(schema, name, version).await?;
let compiled_pipeline = Arc::new(Self::compile_pipeline(&pipeline.0)?);
self.cache
.insert_pipeline_cache(schema, name, version, compiled_pipeline.clone(), false);
self.cache.insert_pipeline_cache(
schema,
name,
version,
compiled_pipeline.clone(),
version.is_none(),
);
Ok(compiled_pipeline)
}
@@ -338,7 +343,7 @@ impl PipelineTable {
name,
Some(version),
p.clone(),
false,
input_version.is_none(),
);
return Ok(p);
}
@@ -362,10 +367,13 @@ impl PipelineTable {
let v = *version;
let p = (pipeline_content.clone(), v);
let with_latest = input_version.is_none();
self.cache
.insert_pipeline_str_cache(found_schema, name, Some(v), p.clone(), with_latest);
self.cache.insert_pipeline_str_cache(
found_schema,
name,
Some(v),
p.clone(),
input_version.is_none(),
);
Ok(p)
}