runledger-postgres 0.1.1

PostgreSQL persistence layer for the Runledger durable job and workflow system
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use super::super::QueryErrorSpec;

pub(super) fn classify_constraint(constraint: &str) -> Option<QueryErrorSpec> {
    match constraint {
        "uq_workflow_runs_type_idempotency_org" | "uq_workflow_runs_type_idempotency_global" => {
            Some(QueryErrorSpec::conflict(
                "workflow.already_enqueued",
                "Workflow is already enqueued for this idempotency key.",
            ))
        }
        "os_workflow_job_linkage_symmetry" => Some(QueryErrorSpec::validation(
            "workflow.linkage_symmetry_violation",
            "Workflow job linkage is invalid.",
        )),
        "os_workflow_job_linkage_symmetry_trigger_table" => Some(QueryErrorSpec::validation(
            "workflow.linkage_symmetry_trigger_table_invalid",
            "Workflow linkage symmetry trigger was called from an unsupported table.",
        )),
        "os_workflow_external_gate_downgrade_external_steps_exist"
        | "os_workflow_external_gate_downgrade_waiting_steps_exist"
        | "os_workflow_external_gate_downgrade_waiting_runs_exist" => {
            Some(QueryErrorSpec::validation(
                "workflow.external_gate_downgrade_blocked",
                "External workflow gate downgrade is blocked by existing workflow state.",
            ))
        }
        _ => None,
    }
}