wakflo_common/utils/
enums.rs

1use crate::{ConnectorPlatform, ConnectorType, JobProcessStatus};
2use std::str::FromStr;
3
4pub fn convert_process_status(status: String) -> JobProcessStatus {
5    if status == *"Running" {
6        JobProcessStatus::Running
7    } else if status == *"Pending" {
8        JobProcessStatus::Pending
9    } else if status == *"Queued" {
10        JobProcessStatus::Queued
11    } else if status == *"Completed" {
12        JobProcessStatus::Completed
13    } else if status == *"Cancelled" {
14        JobProcessStatus::Cancelled
15    } else if status == *"Failed" {
16        JobProcessStatus::Failed
17    } else if status == *"Skipped" {
18        JobProcessStatus::Skipped
19    } else {
20        JobProcessStatus::Pending
21    }
22}
23
24pub fn convert_job_process_status(status: JobProcessStatus) -> String {
25    match status {
26        JobProcessStatus::Running => "Running".to_owned(),
27        JobProcessStatus::Pending => "Pending".to_owned(),
28        JobProcessStatus::Queued => "Queued".to_owned(),
29        JobProcessStatus::Completed => "Completed".to_owned(),
30        JobProcessStatus::Cancelled => "Cancelled".to_owned(),
31        JobProcessStatus::Failed => "Failed".to_owned(),
32        JobProcessStatus::Skipped => "Skipped".to_owned(),
33    }
34}
35
36pub fn connector_platform_from_string(value: String) -> ConnectorPlatform {
37    ConnectorPlatform::from_str(value.as_str()).expect("error: ")
38}
39
40pub fn connector_platform_to_string(platform: ConnectorPlatform) -> String {
41    platform.to_string()
42}
43
44pub fn connector_type_from_string(value: String) -> ConnectorType {
45    ConnectorType::from_str(value.as_str()).expect("error: ")
46}
47
48pub fn connector_type_to_string(platform: ConnectorType) -> String {
49    platform.to_string()
50}
wakflo_common/utils/enums.rs

wakflo_common/utils/
enums.rs
