use file_id and row_id in logs

Author: erhant

compute/src/node/mod.rs

@@ -48,9 +48,9 @@ pub struct DriaComputeNode {
     task_request_batch_tx: Option<mpsc::Sender<TaskWorkerInput>>,
     /// Task worker transmitter to send single tasks.
     task_request_single_tx: Option<mpsc::Sender<TaskWorkerInput>>,
-    // Single tasks, key is `row_id`
+    /// Single tasks, key is `row_id`, which has negligible probability of collision.
     pub pending_tasks_single: HashMap<Uuid, TaskWorkerMetadata>,
-    // Batchable tasks, key is `row_id`
+    // Batchable tasks, key is `row_id`, which has negligible probability of collision.
     pub pending_tasks_batch: HashMap<Uuid, TaskWorkerMetadata>,
     /// Completed single tasks count
     completed_tasks_single: usize,

compute/src/reqres/task.rs

@@ -32,7 +32,8 @@ impl TaskResponder {
             Err(err) => {
                 let err_string = format!("{:#}", err);
                 log::error!(
-                    "Task {} failed due to parsing error: {}",
+                    "Task {}/{} failed due to parsing error: {}",
+                    task.file_id,
                     task.row_id,
                     err_string
                 );
@@ -102,8 +103,9 @@ impl TaskResponder {
             Ok(result) => {
                 // prepare signed and encrypted payload
                 log::info!(
-                    "Publishing {} result for {}",
+                    "Publishing {} result for {}/{}",
                     "task".yellow(),
+                    task_metadata.file_id,
                     task_output.row_id
                 );
 
@@ -129,7 +131,12 @@ impl TaskResponder {
             Err(err) => {
                 // use pretty display string for error logging with causes
                 let err_string = format!("{:#}", err);
-                log::error!("Task {} failed: {}", task_output.row_id, err_string);
+                log::error!(
+                    "Task {}/{} failed: {}",
+                    task_metadata.file_id,
+                    task_output.row_id,
+                    err_string
+                );
 
                 // prepare error payload
                 let error_payload = TaskResponsePayload {