Skip to main content

bpm_engine_storage/
parallel_join.rs

1use async_trait::async_trait;
2
3#[async_trait]
4pub trait ParallelJoinRepo: Send + Sync {
5    async fn ensure_group(&self, group_id: &str, expected: u32) -> anyhow::Result<()>;
6    async fn try_join(&self, group_id: &str) -> anyhow::Result<bool>;
7}