|
@@ -377,7 +377,6 @@ async fn on_receive_task(
|
|
|
info!(target: "taud", "Save the task: ref: {}", task.ref_id);
|
|
info!(target: "taud", "Save the task: ref: {}", task.ref_id);
|
|
|
task.workspace.clone_from(ws_name);
|
|
task.workspace.clone_from(ws_name);
|
|
|
let datastore_path = expand_path(&settings.datastore)?;
|
|
let datastore_path = expand_path(&settings.datastore)?;
|
|
|
- task.save(&datastore_path)?;
|
|
|
|
|
|
|
|
|
|
// Push a notification to a fifo if set
|
|
// Push a notification to a fifo if set
|
|
|
if settings.piped {
|
|
if settings.piped {
|
|
@@ -413,6 +412,8 @@ async fn on_receive_task(
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ task.save(&datastore_path)?;
|
|
|
}
|
|
}
|
|
|
Ok(())
|
|
Ok(())
|
|
|
}
|
|
}
|