stormchaser-engine 1.3.1

A robust, distributed workflow engine for event-driven and human-triggered workflows.
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

use sqlx::{Executor, Postgres};
use stormchaser_model::{EventId, RunId, StepInstanceId};

#[allow(clippy::too_many_arguments)]
/// Insert event correlation.
pub async fn insert_event_correlation<'a, E>(
    executor: E,
    id: EventId,
    step_instance_id: StepInstanceId,
    run_id: RunId,
    correlation_key: &str,
    correlation_value: &str,
) -> Result<sqlx::postgres::PgQueryResult, sqlx::Error>
where
    E: Executor<'a, Database = Postgres>,
{
    sqlx::query(
        "INSERT INTO event_correlations (id, step_instance_id, run_id, correlation_key, correlation_value) VALUES ($1, $2, $3, $4, $5)"
    )
    .bind(id)
    .bind(step_instance_id)
    .bind(run_id)
    .bind(correlation_key)
    .bind(correlation_value)
    .execute(executor)
    .await
}