diff --git a/src/ssb.db.c b/src/ssb.db.c
index 4a767596..95295413 100644
--- a/src/ssb.db.c
+++ b/src/ssb.db.c
@@ -472,6 +472,10 @@ static void _tf_ssb_db_blob_store_after_work(uv_work_t* work, int status)
 	blob_store_work_t* blob_work = work->data;
 	tf_trace_t* trace = tf_ssb_get_trace(blob_work->ssb);
 	tf_trace_begin(trace, "blob_store_after_work");
+	if (status == 0 && *blob_work->id)
+	{
+		tf_ssb_notify_blob_stored(blob_work->ssb, blob_work->id);
+	}
 	if (status != 0)
 	{
 		tf_printf("tf_ssb_db_blob_store_async -> uv_queue_work failed asynchronously: %s\n", uv_strerror(status));
@@ -550,7 +554,6 @@ bool tf_ssb_db_blob_store(tf_ssb_t* ssb, const uint8_t* blob, size_t size, char*
 
 	if (rows)
 	{
-		tf_ssb_notify_blob_stored(ssb, id);
 		if (!out_new)
 		{
 			tf_printf("blob stored %s %zd => %d\n", id, size, result);