windmill_api/models/
asset_progress.rs1use crate::models;
12use serde::{Deserialize, Serialize};
13
14#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
15pub struct AssetProgress {
16 #[serde(rename = "asset_kind")]
17 pub asset_kind: models::AssetKind,
18 #[serde(rename = "asset_path")]
19 pub asset_path: String,
20 #[serde(rename = "status")]
21 pub status: Status,
22 #[serde(rename = "row_count", default, with = "::serde_with::rust::double_option", skip_serializing_if = "Option::is_none")]
23 pub row_count: Option<Option<i64>>,
24 #[serde(rename = "error", default, with = "::serde_with::rust::double_option", skip_serializing_if = "Option::is_none")]
25 pub error: Option<Option<String>>,
26}
27
28impl AssetProgress {
29 pub fn new(asset_kind: models::AssetKind, asset_path: String, status: Status) -> AssetProgress {
30 AssetProgress {
31 asset_kind,
32 asset_path,
33 status,
34 row_count: None,
35 error: None,
36 }
37 }
38}
39#[derive(Clone, Copy, Debug, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize)]
41pub enum Status {
42 #[serde(rename = "running")]
43 Running,
44 #[serde(rename = "materialized")]
45 Materialized,
46 #[serde(rename = "failed")]
47 Failed,
48}
49
50impl Default for Status {
51 fn default() -> Status {
52 Self::Running
53 }
54}
55