async fn arb_swap_steps_optimizer_task<DB: DatabaseRef + Send + Sync + Clone>(
compose_channel_tx: Broadcaster<MessageTxCompose<DB>>,
state_db: &(dyn DatabaseRef<Error = ErrReport> + Send + Sync + 'static),
evm_env: Env,
request: TxComposeData<DB>,
) -> Result<()>