Skip to content

Validate subscriptions

Scheduled task that runs a validation workflow for all active subscriptions.

The list of workflows that should be executed is determined by multiple criteria. First, this task gathers a list of all active subscriptions that are in sync. For each subscription, the list of workflows attached to its product is fetched. From this list, each workflow is selected that meets the following: * The target of the workflow is SYSTEM. * The name of the workflow follows the pattern validate_*.

validate_subscriptions()

Validate all subscriptions using their corresponding validation workflow.

Source code in gso/schedules/validate_subscriptions.py 
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
@shared_task
@scheduler(CronScheduleConfig(name="Subscriptions Validator", minute="10", hour="3"))
def validate_subscriptions() -> None:
    """Validate all subscriptions using their corresponding validation workflow."""
    subscriptions = get_active_insync_subscriptions()
    if not subscriptions:
        logger.info("No subscriptions to validate")
        return

    for subscription in subscriptions:
        validation_workflow = None

        for workflow in subscription.product.workflows:
            if workflow.target == Target.SYSTEM and workflow.name.startswith("validate_"):
                validation_workflow = workflow.name

        if validation_workflow:
            #  Validation workflows only run on subscriptions that are active, even when they could be run on
            #  provisioning subscriptions. E.g. for routers, they can manually be validated when provisioning, but are
            #  not included in this schedule.
            usable_when = TARGET_DEFAULT_USABLE_MAP[Target.SYSTEM]

            if subscription.status in usable_when:
                json = [{"subscription_id": str(subscription.subscription_id)}]

                validate_func = get_execution_context()["validate"]
                validate_func(validation_workflow, json=json)
        else:
            logger.warning(
                "SubscriptionTable has no validation workflow",
                subscription=subscription,
                product=subscription.product.name,
            )