Skip to content
Snippets Groups Projects

Feature/add validation workflows

Merged Karel van Klink requested to merge feature/add-validation-workflows into develop
All threads resolved!
Compare and Show latest version
5 files
+ 80
127
Compare changes
  • Side-by-side
  • Inline
Files
5
@@ -6,7 +6,7 @@ from orchestrator.services.subscriptions import TARGET_DEFAULT_USABLE_MAP, WF_US
from orchestrator.targets import Target
from gso.schedules.scheduling import CronScheduleConfig, scheduler
from gso.services.subscriptions import get_insync_subscriptions
from gso.services.subscriptions import get_active_insync_subscriptions
from gso.worker import celery
logger = structlog.get_logger(__name__)
@@ -16,7 +16,7 @@ logger = structlog.get_logger(__name__)
@scheduler(CronScheduleConfig(name="Subscriptions Validator", minute="10", hour="0"))
def validate_subscriptions() -> None:
"""Validate all subscriptions using their corresponding validation workflow."""
subscriptions = get_insync_subscriptions()
subscriptions = get_active_insync_subscriptions()
if not subscriptions:
logger.info("No subscriptions to validate")
return
Loading