Feature/send validation emails

Send out notification emails for all tasks that have failed in the last hour. Add running this task at an hourly schedule

gso/services/subscriptions.py

@@ -19,6 +19,7 @@ from orchestrator.db import (
 from orchestrator.domain import SubscriptionModel
 from orchestrator.services.subscriptions import query_in_use_by_subscriptions
 from orchestrator.types import SubscriptionLifecycle
+from orchestrator.workflow import ProcessStatus
 from pydantic_forms.types import UUIDstr
 
 from gso.products import ProductName, ProductType
@@ -201,13 +202,15 @@ def count_incomplete_validate_products() -> int:
     """
     return ProcessTable.query.filter(
         ProcessTable.workflow_name == "validate_geant_products",
-        ProcessTable.last_status != "completed",
+        ProcessTable.last_status != ProcessStatus.COMPLETED.value,
     ).count()
 
 
 def get_failed_tasks() -> list[ProcessTable]:
     """Get all tasks that have failed."""
-    return ProcessTable.query.filter(ProcessTable.is_task.is_(True), ProcessTable.last_status == "failed").all()
+    return ProcessTable.query.filter(
+        ProcessTable.is_task.is_(True), ProcessTable.last_status == ProcessStatus.FAILED.value
+    ).all()
 
 
 def get_subscription_by_process_id(process_id: str) -> SubscriptionModel | None: