langgraph-api 0.1.1

Rust Client API of LangGraph
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
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158

/*
 * LangSmith Deployment
 *
 * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
 *
 * The version of the OpenAPI document: 0.1.0
 *
 * Generated by: https://openapi-generator.tech
 */

use crate::models;
use serde::{Deserialize, Serialize};

/// RunCreateStateful : Payload for creating a run.
#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
pub struct RunCreateStateful {
    #[serde(rename = "assistant_id")]
    pub assistant_id: Box<models::RunCreateStatefulAssistantId>,
    /// The checkpoint to resume from.
    #[serde(rename = "checkpoint", skip_serializing_if = "Option::is_none")]
    pub checkpoint: Option<models::CheckpointConfig>,
    #[serde(
        rename = "input",
        default,
        with = "::serde_with::rust::double_option",
        skip_serializing_if = "Option::is_none"
    )]
    pub input: Option<Option<Box<models::Input1>>>,
    #[serde(
        rename = "command",
        default,
        with = "::serde_with::rust::double_option",
        skip_serializing_if = "Option::is_none"
    )]
    pub command: Option<Option<Box<models::Command>>>,
    /// Metadata to assign to the run.
    #[serde(rename = "metadata", skip_serializing_if = "Option::is_none")]
    pub metadata: Option<serde_json::Value>,
    #[serde(rename = "config", skip_serializing_if = "Option::is_none")]
    pub config: Option<Box<models::Config3>>,
    /// Static context added to the assistant.
    #[serde(rename = "context", skip_serializing_if = "Option::is_none")]
    pub context: Option<serde_json::Value>,
    /// Webhook to call after LangGraph API call is done.
    #[serde(rename = "webhook", skip_serializing_if = "Option::is_none")]
    pub webhook: Option<String>,
    #[serde(rename = "interrupt_before", skip_serializing_if = "Option::is_none")]
    pub interrupt_before: Option<Box<models::InterruptBefore1>>,
    #[serde(rename = "interrupt_after", skip_serializing_if = "Option::is_none")]
    pub interrupt_after: Option<Box<models::InterruptAfter1>>,
    #[serde(rename = "stream_mode", skip_serializing_if = "Option::is_none")]
    pub stream_mode: Option<Box<models::StreamMode>>,
    /// Whether to stream output from subgraphs.
    #[serde(rename = "stream_subgraphs", skip_serializing_if = "Option::is_none")]
    pub stream_subgraphs: Option<bool>,
    /// Whether to persist the stream chunks in order to resume the stream later.
    #[serde(rename = "stream_resumable", skip_serializing_if = "Option::is_none")]
    pub stream_resumable: Option<bool>,
    /// The disconnect mode to use. Must be one of 'cancel' or 'continue'.
    #[serde(rename = "on_disconnect", skip_serializing_if = "Option::is_none")]
    pub on_disconnect: Option<OnDisconnect>,
    /// Feedback keys to assign to run.
    #[serde(rename = "feedback_keys", skip_serializing_if = "Option::is_none")]
    pub feedback_keys: Option<Vec<String>>,
    /// Multitask strategy to use. Must be one of 'reject', 'interrupt', 'rollback', or 'enqueue'.
    #[serde(rename = "multitask_strategy", skip_serializing_if = "Option::is_none")]
    pub multitask_strategy: Option<MultitaskStrategy>,
    /// How to handle missing thread. Must be either 'reject' (raise error if missing), or 'create' (create new thread).
    #[serde(rename = "if_not_exists", skip_serializing_if = "Option::is_none")]
    pub if_not_exists: Option<IfNotExists>,
    /// The number of seconds to wait before starting the run. Use to schedule future runs.
    #[serde(rename = "after_seconds", skip_serializing_if = "Option::is_none")]
    pub after_seconds: Option<f64>,
    /// Whether to checkpoint during the run.
    #[serde(rename = "checkpoint_during", skip_serializing_if = "Option::is_none")]
    pub checkpoint_during: Option<bool>,
    /// Durability level for the run. Must be one of 'sync', 'async', or 'exit'.
    #[serde(rename = "durability", skip_serializing_if = "Option::is_none")]
    pub durability: Option<Durability>,
}

impl RunCreateStateful {
    /// Payload for creating a run.
    pub fn new(assistant_id: models::RunCreateStatefulAssistantId) -> RunCreateStateful {
        RunCreateStateful {
            assistant_id: Box::new(assistant_id),
            checkpoint: None,
            input: None,
            command: None,
            metadata: None,
            config: None,
            context: None,
            webhook: None,
            interrupt_before: None,
            interrupt_after: None,
            stream_mode: None,
            stream_subgraphs: None,
            stream_resumable: None,
            on_disconnect: None,
            feedback_keys: None,
            multitask_strategy: None,
            if_not_exists: None,
            after_seconds: None,
            checkpoint_during: None,
            durability: None,
        }
    }
}
/// The disconnect mode to use. Must be one of 'cancel' or 'continue'.
#[derive(
    Clone, Copy, Debug, Default, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize,
)]
pub enum OnDisconnect {
    #[serde(rename = "cancel")]
    #[default]
    Cancel,
    #[serde(rename = "continue")]
    Continue,
}
/// Multitask strategy to use. Must be one of 'reject', 'interrupt', 'rollback', or 'enqueue'.
#[derive(
    Clone, Copy, Debug, Default, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize,
)]
pub enum MultitaskStrategy {
    #[serde(rename = "reject")]
    #[default]
    Reject,
    #[serde(rename = "rollback")]
    Rollback,
    #[serde(rename = "interrupt")]
    Interrupt,
    #[serde(rename = "enqueue")]
    Enqueue,
}
/// How to handle missing thread. Must be either 'reject' (raise error if missing), or 'create' (create new thread).
#[derive(
    Clone, Copy, Debug, Default, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize,
)]
pub enum IfNotExists {
    #[serde(rename = "create")]
    #[default]
    Create,
    #[serde(rename = "reject")]
    Reject,
}
/// Durability level for the run. Must be one of 'sync', 'async', or 'exit'.
#[derive(
    Clone, Copy, Debug, Default, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize,
)]
pub enum Durability {
    #[serde(rename = "sync")]
    #[default]
    Sync,
    #[serde(rename = "async")]
    Async,
    #[serde(rename = "exit")]
    Exit,
}