pub async fn execute_workflow(
state: &AppState,
workflow: &WorkflowSpec,
tenant_context: TenantContext,
trigger_event: Option<String>,
source_event_id: Option<String>,
task_id: Option<String>,
dry_run: bool,
) -> Result<WorkflowRunRecord>