Asyncronous notification for mf enforcement rules

backend/dataall/modules/metadata_forms/__init__.py

@@ -1,7 +1,9 @@
-from typing import List, Type
-
+from typing import List, Type, Set
+import logging
 from dataall.base.loader import ModuleInterface, ImportMode
 
+log = logging.getLogger(__name__)
+
 
 class MetadataFormsApiModuleInterface(ModuleInterface):
     """Implements ModuleInterface for Metadata Forms GraphQl lambda"""
@@ -19,3 +21,19 @@ def depends_on() -> List[Type['ModuleInterface']]:
         from dataall.modules.datasets_base import DatasetBaseApiModuleInterface
 
         return [DatasetBaseApiModuleInterface]
+
+
+class MetadataFormAsyncHandlersModuleInterface(ModuleInterface):
+    """Implements ModuleInterface for metadataform async lambda"""
+
+    @staticmethod
+    def is_supported(modes: Set[ImportMode]):
+        return ImportMode.HANDLERS in modes
+
+    def __init__(self):
+        import dataall.modules.metadata_forms.handlers
+        import dataall.modules.metadata_forms.db.metadata_form_models
+        import dataall.modules.metadata_forms.db.metadata_form_repository
+        import dataall.modules.metadata_forms.services.metadata_form_enforcement_service
+
+        log.info('Metadata Form handlers have been imported')

backend/dataall/modules/metadata_forms/db/metadata_form_repository.py

@@ -391,5 +391,5 @@ def update_version_in_rules(session, uri, version):
 
     @staticmethod
     def delete_rule(session, rule_uri):
-        session.query(MetadataFormEnforcementRule).filter(uri=rule_uri).delete()
+        session.query(MetadataFormEnforcementRule).filter(MetadataFormEnforcementRule.uri == rule_uri).delete()
         session.commit()

backend/dataall/modules/metadata_forms/handlers/__init__.py

@@ -0,0 +1,3 @@
+from dataall.modules.metadata_forms.handlers import metadata_form_handler
+
+__all__ = ['metadata_form_handler']

backend/dataall/modules/metadata_forms/handlers/metadata_form_handler.py

@@ -0,0 +1,17 @@
+import logging
+
+from dataall.core.tasks.service_handlers import Worker
+from dataall.core.tasks.db.task_models import Task
+from dataall.modules.metadata_forms.services.metadata_form_enforcement_service import MetadataFormEnforcementService
+
+log = logging.getLogger(__name__)
+
+
+class EcsMetadataFormHandler:
+    @staticmethod
+    @Worker.handler(path='metadata_form.enforcement.notify')
+    def notify_owners_of_enforcement(engine, task: Task):
+        with engine.scoped_session() as session:
+            MetadataFormEnforcementService.notify_owners_of_enforcement(
+                session=session, rule_uri=task.targetUri, mf_name=task.payload.get('mf_name')
+            )