fix(coprocessor): do not update dependence chain last_updated_at on release

Author: antoniupop

…8d0388c50a8b842be000d9c804fe17eba9e.json …dfa34bf30db25bcf69a333a341b17b5557a.jsoncoprocessor/fhevm-engine/.sqlx/query-aab520e6ce550c4dec799427739a68d0388c50a8b842be000d9c804fe17eba9e.json renamed to coprocessor/fhevm-engine/.sqlx/query-94e9cb426316068aa285da33e7fd1dfa34bf30db25bcf69a333a341b17b5557a.json coprocessor/fhevm-engine/.sqlx/query-aab520e6ce550c4dec799427739a68d0388c50a8b842be000d9c804fe17eba9e.json renamed to coprocessor/fhevm-engine/.sqlx/query-94e9cb426316068aa285da33e7fd1dfa34bf30db25bcf69a333a341b17b5557a.json

@@ -279,10 +279,6 @@ impl LockMngr {
                     WHEN status = 'processing' AND $3::bool THEN 'processed'       -- mark as processed
                     WHEN status = 'processing' AND NOT $3::bool THEN 'updated'     -- revert to updated so it can be re-acquired
                     ELSE status
-                END,
-                last_updated_at = CASE
-                    WHEN status = 'processing' THEN NOW()
-                    ELSE last_updated_at
                 END
             WHERE worker_id = $1
             AND dependence_chain_id = $2

coprocessor/fhevm-engine/tfhe-worker/src/dependence_chain.rs

@@ -292,7 +292,6 @@ async fn query_ciphertexts<'a>(
         error!(target: "tfhe_worker", { error = %err }, "error while querying ciphertexts");
         err
     })?;
-
     s.end();
     // index ciphertexts in hashmap
     let mut ciphertext_map: HashMap<Vec<u8>, (i16, Vec<u8>)> =
@@ -559,6 +558,12 @@ async fn build_transaction_graph_and_execute<'a>(
     let cts_to_query = tx_graph.needed_map.keys().cloned().collect::<Vec<_>>();
     let ciphertext_map =
         query_ciphertexts(&cts_to_query, *tenant_id, trx, tracer, loop_ctx).await?;
+    // Check if we retrieved all needed CTs - if not, we may not want to proceed to execution
+    if cts_to_query.len() != ciphertext_map.len() {
+        warn!(target: "tfhe_worker", { missing_inputs = ?(cts_to_query.len() - ciphertext_map.len()) }, "some inputs are missing to execute the dependence chain");
+        return Ok(tx_graph);
+    }
+
     for (handle, (ct_type, mut ct)) in ciphertext_map.into_iter() {
         tx_graph.add_input(
             &handle,