Patch20250130: fixup the on_success function recieve invalid parameter (#202)

colorzzr · web-flow · commit 3bf319960242 · 2025-02-03T13:01:29.000-05:00
* make the concurrency of uploading jobsbs configurable

* also make upload_chunk_size configurable

* remove the internal cache of the result of chunk upload. Instead, using active job count to ensure all jobs finish

* bumpup version

* update test cases to adopt new logic of chunk upload

* fixup the on_success function recieve wrong parameter
diff --git a/app/services/file_manager/file_upload/file_upload.py b/app/services/file_manager/file_upload/file_upload.py
@@ -242,7 +242,7 @@ def simple_upload(  # noqa: C901
         # the on_success api will be called after all chunk uploaded
         res = pool.apply_async(
             upload_client.on_succeed,
-            args=(file_object),
+            args=(file_object,),
         )
         on_success_res.append(res)
 
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "app"
-version = "3.12.2"
+version = "3.12.3"
 description = "This service is designed to support pilot platform"
 authors = ["Indoc Systems"]
 

Original file line number	Diff line number	Diff line change
`@@ -242,7 +242,7 @@ def simple_upload( # noqa: C901`
`242`	`242`	`# the on_success api will be called after all chunk uploaded`
`243`	`243`	`res = pool.apply_async(`
`244`	`244`	`upload_client.on_succeed,`
`245`		`- args=(file_object),`
	`245`	`+ args=(file_object,),`
`246`	`246`	`)`
`247`	`247`	`on_success_res.append(res)`
`248`	`248`