fix: make call to cleanup_blobs task immutable

and ignore results

Author: matthiasschaub

sketch_map_tool/routes.py

@@ -163,7 +163,7 @@ def digitize_results_post(lang="en") -> Response:
     group_ = group([task_1, task_2])
     chain_ = chain(
         group_,
-        cleanup_blobs.signature(kwargs={"map_frame_uuids": list(set(uuids))}),
+        cleanup_blobs.signature([list(set(uuids))], immutable=True),
     )
     chain_result = chain_.apply_async()
 

sketch_map_tool/tasks.py

@@ -235,12 +235,7 @@ def cleanup_map_frames():
     return True
 
 
-@celery.task
-def cleanup_blobs(*_, file_ids: list[int]):
-    """Cleanup uploaded files stored in the database.
-
-    Arguments are ignored. They are only part of the signature because of the usage in
-    a celery chain.
-    """
+@celery.task(ignore_result=True)
+def cleanup_blobs(file_ids: list[int]):
+    """Cleanup uploaded files stored in the database."""
     db_client_celery.cleanup_blob(file_ids)
-    return True

tests/integration/test_celery_tasks.py

@@ -46,5 +46,5 @@ def test_cleanup_blobs(uuid_create, flask_app):
         with client_flask.open_connection().cursor() as curs:
             curs.execute("SELECT id FROM blob WHERE map_frame_uuid = %s", [uuid_create])
             file_ids = curs.fetchall()[0]
-    task = tasks.cleanup_blobs.apply_async(kwargs={"file_ids": file_ids})
+    task = tasks.cleanup_blobs.apply_async(file_ids)
     task.wait()