add celery decorator to task functions #172

This commit is contained in:
rimu 2024-05-03 06:27:25 +12:00
parent e2e20c76a0
commit ec88d84775

View file

@ -1245,6 +1245,7 @@ def user_inbox(actor):
return resp
@celery.task
def process_user_follow_request(request_json, activitypublog_id, remote_user_id):
activity_log = ActivityPubLog.query.get(activitypublog_id)
local_user_ap_id = request_json['object']
@ -1285,6 +1286,7 @@ def process_user_follow_request(request_json, activitypublog_id, remote_user_id)
db.session.commit()
@celery.task
def process_user_undo_follow_request(request_json, activitypublog_id, remote_user_id):
activity_log = ActivityPubLog.query.get(activitypublog_id)
local_user_ap_id = request_json['object']['object']