You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
While try to play around with latte, I was looking on how can I add data validation to a workflow,
and I've found the execute functions are always return empty/nil/unit
/// Executes an ad-hoc CQL statement with no parameters. Does not prepare.pubasyncfnexecute(&self,cql:&str) -> Result<(),CassError>{let start_time = self.stats.try_lock().unwrap().start_request();let rs = self.session.query(cql,()).await;let duration = Instant::now() - start_time;self.stats.try_lock().unwrap().complete_request(duration,&rs);
rs.map_err(|e| CassError::query_execution_error(cql,&[], e))?;Ok(())}/// Executes a statement prepared and registered earlier by a call to `prepare`.pubasyncfnexecute_prepared(&self,key:&str,params:Value) -> Result<(),CassError>{let statement = self.statements.get(key).ok_or_else(|| CassError(CassErrorKind::PreparedStatementNotFound(key.to_string())))?;let params = bind::to_scylla_query_params(¶ms)?;let start_time = self.stats.try_lock().unwrap().start_request();let rs = self.session.execute(statement, params.clone()).await;let duration = Instant::now() - start_time;self.stats.try_lock().unwrap().complete_request(duration,&rs);
rs.map_err(|e| CassError::query_execution_error(statement.get_statement(),¶ms, e))?;Ok(())}
so in cases the query works but comes out empty, latte consider is as correct, while I would like to be able to consider it as
error, and maybe even stop the workflow cause of that
The text was updated successfully, but these errors were encountered:
While try to play around with latte, I was looking on how can I add data validation to a workflow,
and I've found the
execute
functions are always return empty/nil/unitso in cases the query works but comes out empty, latte consider is as correct, while I would like to be able to consider it as
error, and maybe even stop the workflow cause of that
The text was updated successfully, but these errors were encountered: