diff --git a/upub/worker/src/local.rs b/upub/worker/src/local.rs index f9cad61a..6385901c 100644 --- a/upub/worker/src/local.rs +++ b/upub/worker/src/local.rs @@ -38,7 +38,7 @@ pub async fn process(ctx: Context, job: &model::job::Model) -> crate::JobResult< .select_only() .select_column(model::actor::Column::Id) .into_tuple::() - .one(ctx.db()) + .one(&tx) .await { tmp = tmp.replacen(full, &format!("@{user}"), 1);