Skip to content
Snippets Groups Projects
Verified Commit c8e4965d authored by Karel van Klink's avatar Karel van Klink :smiley_cat:
Browse files

Use ProcessStatus enum values

parent 04353eb8
No related branches found
No related tags found
1 merge request!239Feature/send validation emails
Pipeline #88151 passed
......@@ -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:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment