diff --git a/server/src/routes/internal_ingest.rs b/server/src/routes/internal_ingest.rs index 32834398c..6f3666f28 100644 --- a/server/src/routes/internal_ingest.rs +++ b/server/src/routes/internal_ingest.rs @@ -140,11 +140,12 @@ pub async fn ingest_files_from_executor( IndexifyAPIError::bad_request("task_result is required before diagnostics") })?; let file_name = format!( - "{}.{}.{}.{}.{}", + "{}.{}.{}.{}.{}.{}", task_result.namespace, task_result.compute_graph, task_result.compute_fn, task_result.invocation_id, + task_result.task_id, name, ); let res = write_to_disk(state.clone().blob_storage, &mut field, &file_name).await?;