This commit is contained in:
Shubham Mishra
2025-11-04 20:33:45 +05:30
committed by Shubham Mishra
parent 3a91b7fbf3
commit 896bbdf6ce
4 changed files with 5 additions and 5 deletions
+1 -1
View File
@@ -85,7 +85,7 @@ impl Host {
let sql_span = tracing::trace_span!("execute_sql", total_duration = tracing::field::Empty,);
let _guard = sql_span.enter();
let result = sql::execute::run(&db, &body, auth.clone(), Some(&module_host), auth.caller, &mut header)
let result = sql::execute::run(&db, &body, auth, Some(&module_host), auth.caller, &mut header)
.await
.map_err(|e| {
log::warn!("{e}");
+3 -2
View File
@@ -1517,7 +1517,8 @@ impl RelationalDB {
/// 3. Deserializing the return value from the view execution
/// 4. Inserting all rows from the return value into the view table, with the arg_id
/// set to the inserted view argument's id.
/// The `typespace` is needed for deserializing the return value.
/// The `typespace` is needed for deserializing the return value.
#[allow(clippy::too_many_arguments)]
pub fn evaluate_view(
&self,
tx: &mut MutTxId,
@@ -1543,7 +1544,7 @@ impl RelationalDB {
st_view_row.is_anonymous,
);
let arg_id = tx.get_or_insert_st_view_arg(&args.get_bsatn())?;
let arg_id = tx.get_or_insert_st_view_arg(args.get_bsatn())?;
let input_rows = product![
if is_anonymous {
-1
View File
@@ -440,7 +440,6 @@ pub fn create_table_from_view_def(
module_def: &ModuleDef,
view_def: &ViewDef,
) -> anyhow::Result<()> {
println!("Creating view table for view {:?}", &view_def);
stdb.create_view(tx, module_def, view_def)
.with_context(|| format!("failed to create table for view {}", &view_def.name))?;
Ok(())
@@ -712,7 +712,7 @@ impl InstanceCommon {
WORKER_METRICS
.wasm_instance_errors
.with_label_values(
&caller_identity,
caller_identity,
&self.info.module_hash,
&caller_connection_id.unwrap_or(ConnectionId::ZERO),
reducer_name,