wakflo_core/contracts/
runnable_plugin.rs

1use crate::connector::JobInstanceState;
2use crate::TaskContext;
3use anyhow::Result;
4use std::sync::Arc;
5
6#[async_trait::async_trait]
7pub trait RunnablePlugin: Sync + Send {
8    async fn execute(&self, context: Arc<TaskContext>) -> Result<JobInstanceState>;
9}