rewrite the download function to work with multiple threads

This commit is contained in:
2025-04-16 09:11:05 +01:00
parent 4a248d14ac
commit 7888f1bddb
4 changed files with 65 additions and 47 deletions
+5 -3
View File
@@ -193,7 +193,8 @@ class CleverSwarmAmqpAdapter(CleverThisServiceAdapter):
message,
_args,
api_method=_route.endpoint,
success_code=_route.status_code
success_code=_route.status_code,
loop=self.loop
)
return AMQResponseFactory.of(message.id, 404, "text/plain",
@@ -237,7 +238,7 @@ class CleverSwarmAmqpAdapter(CleverThisServiceAdapter):
else:
# needed for /login input
if arg == 'authenticated_user':
_form_data['authenticated_user'] = auth_user
_verified_args['authenticated_user'] = auth_user
if _required_args[arg].__name__ == 'OAuth2PasswordRequestForm':
try:
_verified_args[arg] = OAuth2PasswordRequestForm(**_form_data)
@@ -248,7 +249,8 @@ class CleverSwarmAmqpAdapter(CleverThisServiceAdapter):
message,
_verified_args,
api_method=_route.endpoint,
success_code=_route.status_code if _route.status_code else 200
success_code=_route.status_code if _route.status_code else 200,
loop=self.loop
)
return AMQResponseFactory.of(message.id, 404, "text/plain",