minke.yu/sglang
1
0
Fork 0
Code Issues Pull Requests Actions 12 Packages Projects Releases Wiki Activity

[smg] fix type complexity for workflow run_if (#16981)

Browse Source
This commit is contained in:
Simo Lin
2026-01-12 15:41:52 -08:00
committed by GitHub
parent e0ac559ae1
commit c6a64e9f69
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sgl-model-gateway/src/workflow/definition.rs
+4 -2
View File
@@ -14,6 +14,9 @@ use super::{
types::{FailureAction, RetryPolicy, StepId, WorkflowContext, WorkflowData, WorkflowId}, types::{FailureAction, RetryPolicy, StepId, WorkflowContext, WorkflowData, WorkflowId},
}; };
/// A condition function that determines whether a step should run.
pub type StepCondition<D> = Arc<dyn Fn(&WorkflowContext<D>) -> bool + Send + Sync>;
/// Errors that can occur during workflow validation /// Errors that can occur during workflow validation
#[derive(Debug, Clone, thiserror::Error)] #[derive(Debug, Clone, thiserror::Error)]
pub enum ValidationError { pub enum ValidationError {
@@ -43,8 +46,7 @@ pub struct StepDefinition<D: WorkflowData> {
/// Run step at or after this time (after dependencies satisfied) /// Run step at or after this time (after dependencies satisfied)
pub scheduled_at: Option<DateTime<Utc>>, pub scheduled_at: Option<DateTime<Utc>>,
/// Condition to evaluate; if false, step is skipped /// Condition to evaluate; if false, step is skipped
#[allow(clippy::type_complexity)] pub run_if: Option<StepCondition<D>>,
pub run_if: Option<Arc<dyn Fn(&WorkflowContext<D>) -> bool + Send + Sync>>,
} }
impl<D: WorkflowData> fmt::Debug for StepDefinition<D> { impl<D: WorkflowData> fmt::Debug for StepDefinition<D> {