Feat/mrq filter by low confidence

backend/prompt_studio/prompt_studio_registry_v2/urls.py

@@ -1,3 +1,15 @@
+from django.urls import path
 from rest_framework.urlpatterns import format_suffix_patterns
 
-urlpatterns = format_suffix_patterns([])
+from .views import PromptStudioRegistryView
+
+urlpatterns = [
+    path(
+        "registry/",
+        PromptStudioRegistryView.as_view({"get": "list"}),
+        name="prompt_studio_registry_list",
+    ),
+]
+
+# Optional: Apply format suffix patterns
+urlpatterns = format_suffix_patterns(urlpatterns)

backend/workflow_manager/endpoint_v2/destination.py

@@ -36,6 +36,7 @@
 from workflow_manager.workflow_v2.file_history_helper import FileHistoryHelper
 from workflow_manager.workflow_v2.models.file_history import FileHistory
 from workflow_manager.workflow_v2.models.workflow import Workflow
+from workflow_manager.workflow_v2.utils import WorkflowUtil
 
 from backend.constants import FeatureFlag
 from backend.exceptions import UnstractFSException
@@ -182,10 +183,8 @@ def handle_output(
         if connection_type == WorkflowEndpoint.ConnectionType.FILESYSTEM:
             self.copy_output_to_output_directory()
         elif connection_type == WorkflowEndpoint.ConnectionType.DATABASE:
-            if (
-                file_hash.file_destination
-                == WorkflowEndpoint.ConnectionType.MANUALREVIEW
-            ):
+            result = self.get_result(file_history)
+            if WorkflowUtil.db_rule_check(result, workflow, file_hash.file_destination):
                 self._push_data_to_queue(file_name, workflow, input_file_path)
             else:
                 self.insert_into_db(input_file_path=input_file_path)
@@ -287,6 +286,7 @@ def insert_into_db(self, input_file_path: str) -> None:
         # If data is None, don't execute CREATE or INSERT query
         if not data:
             return
+
         # Remove metadata from result
         # Tool text-extractor returns data in the form of string.
         # Don't pop out metadata in this case.

backend/workflow_manager/workflow_v2/utils.py

@@ -1,4 +1,4 @@
-from typing import Any
+from typing import Any, Optional
 
 from workflow_manager.endpoint_v2.dto import FileHash
 from workflow_manager.workflow_v2.models.workflow import Workflow
@@ -59,3 +59,24 @@ def add_file_destination_filehash(
             destination modified.
         """
         return file_hash
+
+    @staticmethod
+    def db_rule_check(
+        result: Optional[Any],
+        workflow_id: Workflow,
+        file_destination: Optional[tuple[str, str]],
+    ) -> bool:
+        """Placeholder method to check the db rules - MRQ
+
+        Args:
+            result (Optional[Any]): The result dictionary containing
+            confidence_data.
+            workflow_id (str): The ID of the workflow to retrieve the rules.
+            file_destination (Optional[tuple[str, str]]): The destination of
+            the file (e.g., MANUALREVIEW or other).
+
+        Returns:
+            bool: True if the field_key conditions are met based on rule logic
+            and file destination.
+        """
+        return False

frontend/src/components/agency/configure-connector-modal/ConfigureConnectorModal.jsx

@@ -34,6 +34,7 @@ function ConfigureConnectorModal({
   connType,
   selectedItemName,
   setSelectedItemName,
+  workflowDetails,
 }) {
   const [activeKey, setActiveKey] = useState("1");
   useEffect(() => {
@@ -191,7 +192,10 @@ function ConfigureConnectorModal({
               <ManageFiles selectedItem={connectorId} />
             )}
             {activeKey === "MANUALREVIEW" && (
-              <DBRules connDetails={connDetails} />
+              <DBRules
+                connDetails={connDetails}
+                workflowDetails={workflowDetails}
+              />
             )}
           </Col>
         </Row>
@@ -218,6 +222,7 @@ ConfigureConnectorModal.propTypes = {
   connType: PropTypes.string.isRequired,
   selectedItemName: PropTypes.string,
   setSelectedItemName: PropTypes.func.isRequired,
+  workflowDetails: PropTypes.object,
 };
 
 export { ConfigureConnectorModal };

frontend/src/components/agency/ds-settings-card/DsSettingsCard.jsx

@@ -47,7 +47,7 @@ const needToRemove = {
 
 function DsSettingsCard({ type, endpointDetails, message }) {
   const workflowStore = useWorkflowStore();
-  const { source, destination, allowChangeEndpoint } = workflowStore;
+  const { source, destination, allowChangeEndpoint, details } = workflowStore;
   const [options, setOptions] = useState({});
   const [openModal, setOpenModal] = useState(false);
 
@@ -490,6 +490,7 @@ function DsSettingsCard({ type, endpointDetails, message }) {
         connType={connType}
         selectedItemName={selectedItemName}
         setSelectedItemName={setSelectedItemName}
+        workflowDetails={details}
       />
     </>
   );