async fn arb_swap_steps_optimizer_task<DB: DatabaseRef<Error = KabuDBError> + Database<Error = KabuDBError> + DatabaseCommit + Send + Sync + Clone>(
compose_channel_tx: Sender<MessageSwapCompose<DB>>,
_state_db: DB,
block_number: u64,
block_timestamp: u64,
request: SwapComposeData<DB>,
) -> Result<()>