v1.19.0 (#298)

* Added weak supervision failed notification

* Org user search - Role SELECT ORG FIRT

* Add coroutine check for non async clients.

* sub ref

---------

Co-authored-by: Lina <[email protected]>
Co-authored-by: anmarhindi <[email protected]>

Author: 3 people

controller/attribute/llm_response_tmpl.py

@@ -263,8 +263,12 @@ async def get_chat_completion_async_4a90ecec_fc72_45af_ba0d_ae9a2dc4674c(
             response_format={"type": "json_object"},
             **kwargs,
         )
+
     if close_after:
-        await client.close()
+        result = client.close()
+        if asyncio.iscoroutine(result):
+            await result
+
     return completion
 
 

controller/notification/notification_data.py

@@ -194,7 +194,7 @@
         "docs": enums.DOCS.WEAK_SUPERVISION.value,
     },
     enums.NotificationType.WEAK_SUPERVISION_TASK_FAILED.value: {
-        "message_template": "Could not start weak supervision.",
+        "message_template": "Weak supervision failed.",
         "title": "Weak supervision",
         "level": enums.Notification.ERROR.value,
         "page": enums.Pages.INFORMATION_SOURCES.value,

controller/weak_supervision/manager.py

@@ -90,6 +90,11 @@ def execution_pipeline(
         except Exception as e:
             print(traceback.format_exc(), flush=True)
             general.rollback()
+            create_notification(
+                NotificationType.WEAK_SUPERVISION_TASK_FAILED,
+                user_id,
+                project_id,
+            )
             weak_supervision.update_state(
                 project_id,
                 weak_supervision_task_id,

fast_api/routes/organization.py

@@ -184,7 +184,7 @@ def change_organization(request: Request, body: ChangeOrganizationBody = Body(..
 def get_user_roles(request: Request):
     auth_manager.check_admin_access(request.state.info)
     data = user_manager.get_user_roles()
-    return pack_json_result(data)
+    return pack_json_result(data, wrap_for_frontend=False)
 
 
 # in use admin-dashboard (08.01.25)