@@ -20,30 +20,32 @@ async def copy_folders_from_project(
2020 job_id_data : AsyncJobNameData ,
2121 body : FoldersBody ,
2222) -> AsyncJobGet :
23+ task_name = deep_copy_files_from_project .__name__
2324 task_uuid = await get_celery_client (app ).submit_task (
2425 task_metadata = TaskMetadata (
25- name = deep_copy_files_from_project . __name__ ,
26+ name = task_name ,
2627 ),
2728 task_context = job_id_data .model_dump (),
2829 user_id = job_id_data .user_id ,
2930 body = body ,
3031 )
3132
32- return AsyncJobGet (job_id = task_uuid )
33+ return AsyncJobGet (job_id = task_uuid , job_name = task_name )
3334
3435
3536@router .expose ()
3637async def start_export_data (
3738 app : FastAPI , job_id_data : AsyncJobNameData , paths_to_export : list [PathToExport ]
3839) -> AsyncJobGet :
40+ task_name = export_data .__name__
3941 task_uuid = await get_celery_client (app ).submit_task (
4042 task_metadata = TaskMetadata (
41- name = export_data . __name__ ,
43+ name = task_name ,
4244 ephemeral = False ,
4345 queue = TasksQueue .CPU_BOUND ,
4446 ),
4547 task_context = job_id_data .model_dump (),
4648 user_id = job_id_data .user_id ,
4749 paths_to_export = paths_to_export ,
4850 )
49- return AsyncJobGet (job_id = task_uuid )
51+ return AsyncJobGet (job_id = task_uuid , job_name = task_name )
0 commit comments