async fn state_change_arb_searcher_task<DB: DatabaseRef<Error = ErrReport> + DatabaseCommit + Send + Sync + Clone + Default + 'static>(
thread_pool: Arc<ThreadPool>,
backrun_config: BackrunConfig,
state_update_event: StateUpdateEvent<DB>,
market: SharedState<Market>,
swap_request_tx: Broadcaster<MessageTxCompose<DB>>,
pool_health_monitor_tx: Broadcaster<MessageHealthEvent>,
) -> Result<()>